jms - ActiveMQ - handle connection, session, producer and concumer opon failover -


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