https://github.com/apache/activemq/blob/master/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
On Dec 29, 2016 3:47 AM, "Jaspreet Kaur" <jk...@quark.com> wrote:
> Hi,
>
> I am using ActiveMQ 5.14.1.
> I would like to observer in source code how/on what basis a JMS client
> connection & consumers are reconnected to second broker in case the first
> broker has been killed.
>
> I have create a JMS client like..
> ConnectionFactory connectionFactory = (ConnectionFactory) jndiLookup(
> "ConnectionFactory",
> "org.apache.activemq.jndi.
> ActiveMQInitialContextFactory",
>
> "failover:(discovery://(multicast://default?wireFormat.
> maxInactivityDuration=0&group=qpp))");
> Connection connection = connectionFactory.
> createConnection();
> Session jmsSession = connection.createSession(
> false,
> Session.AUTO_ACKNOWLEDGE);
> Topic topic = jmsSession.createTopic("t14");
> MessageConsumer messageConsumer =
> jmsSession.createConsumer(topic);
> messageConsumer.setMessageListener(new
> QpsMessageListener());
> connection.start();
> ...............
> ..........
>
> Thanks
> Jaspreet
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Where-can-I-find-the-JMS-connection-reconnection-logic-in-
> activemq-client-source-tp4720765.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
