i use failover transport feature using following pattern in broker url
failover:(tcp://host:port)
init code goes follow:
factory = new pooledconnectionfactory(broker_url); connection = factory.createconnection(); connection.start();
the put message code looks more or less this:
session = connection.createsession( false, session.auto_acknowledge ); destination destqueue = new activemqqueue(queue); messageproducer producer = session.createproducer(destqueue); textmessage msg = session.createtextmessage(message); producer.send(msg);
when failover occurs -
[org.apache.activemq.transport.failover.failovertransport] transport (broker) failed, reason: , attempting automatically reconnect: java.net.socketexception: recv failed: connection aborted peer , got reconnected after [org.apache.activemq.transport.failover.failovertransport] failed connect [broker] after: 10 attempt(s) continuing retry. 08:55:29,596 info [org.apache.activemq.transport.failover.failovertransport] reconnected broker
do have reinitiate connection? or more specific, have connection object able produce/consume message after failover?
thanks
the whole point of failover transport handle reconnection you. logs you've shown indicate successful reconnect cycle transport has continued retry connect broker , did so.
Comments
Post a Comment