activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: Failover reconnection questions
Date Tue, 20 Sep 2011 13:35:16 GMT
you will get more information with TRACE level logging for FailoverTransport

There are a bunch of retry config options but the default is to
continue to retry for ever.
If you want to see what it does/can do, the source is at:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?view=markup

On 20 September 2011 13:25, RickSnz <ricardo.sanz@altran.es> wrote:
> Hello,
>
> I've just started using Activemq so please excuse me if this has been
> already answered.
>
> I'm using failover with two brokers, host1 and host2, and this connection
> uri:
>
> failover:(tcp://host1:61617,tcp://host2:61617)
>
> So the consumer randomly connects to one of the brokers. When i stop that
> broker, the consumer reconnects to the other one. However, if after this i
> stop the second one, the program stops instead of trying to reconnect. It
> launches the same exception as when it successfully reconnects, and tries to
> reconnect, but the program stops. Here are the traces after it connected to
> host 2,  reconnected to host1 and i stopped it:
>
> 14:19:27.433 [ActiveMQ Transport: tcp://host1/ip1:61617] DEBUG
> o.a.a.transport.tcp.TcpTransport - Stopping transport tcp://host1/ip1:61617
> 14:19:27.433 [ActiveMQ Transport: tcp://host1/ip1:61617] WARN
> o.a.a.t.failover.FailoverTransport - Transport (host1/ip1:61617) failed to
> tcp://host1:61617 , attempting to automatically reconnect due to:
> java.io.EOFException
> 14:19:27.448 [ActiveMQ Transport: tcp://host1/ip1:61617] DEBUG
> o.a.a.t.failover.FailoverTransport - Transport failed with the following
> exception:
> java.io.EOFException: null
>        at java.io.DataInputStream.readInt(DataInputStream.java:375) ~[na:1.6.0_23]
>        at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
> ~[activemq-core-5.5.0.jar:5.5.0]
>        at
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
> ~[activemq-core-5.5.0.jar:5.5.0]
>        at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
> ~[activemq-core-5.5.0.jar:5.5.0]
>        at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
> ~[activemq-core-5.5.0.jar:5.5.0]
>        at java.lang.Thread.run(Thread.java:662) [na:1.6.0_23]
> 14:19:27.448 [ActiveMQ Transport: tcp://host1/ip1:61617] DEBUG
> o.apache.activemq.ActiveMQConnection - transport interrupted, dispatchers: 1
> 14:19:27.448 [ActiveMQ Transport: tcp://host1/ip1:61617] DEBUG
> o.apache.activemq.ActiveMQConnection - notified failover transport
> (unconnected) of pending interruption processing for:
> ID:28APO0174-2998-1316521115351-0:1
> 14:19:27.448 [ActiveMQConnection[ID:28APO0174-2998-1316521115351-0:1]
> Scheduler] DEBUG o.a.activemq.ActiveMQMessageConsumer -
> ID:28APO0174-2998-1316521115351-0:1:1:1 clearing dispatched list (0) on
> transport interrupt
> 14:19:27.448 [ActiveMQConnection[ID:28APO0174-2998-1316521115351-0:1]
> Scheduler] DEBUG o.apache.activemq.ActiveMQConnection -
> transportInterruptionProcessingComplete for:
> ID:28APO0174-2998-1316521115351-0:1
> 14:19:27.448 [ActiveMQConnection[ID:28APO0174-2998-1316521115351-0:1]
> Scheduler] DEBUG o.apache.activemq.ActiveMQConnection - notified failover
> transport (unconnected) of interruption completion for:
> ID:28APO0174-2998-1316521115351-0:1
> 14:19:27.448 [ActiveMQ Task-3] DEBUG o.a.a.t.failover.FailoverTransport -
> urlList connectionList:[tcp://host2:61617, tcp://host1:61617], from:
> [tcp://host1:61617, tcp://host2:61617]
> 14:19:27.448 [ActiveMQ Task-3] DEBUG o.a.a.t.failover.FailoverTransport -
> Attempting connect to: tcp://host2:61617
>
> Also, if before stopping the second broker, i start again the first one, the
> same happens, the program crashes.
>
> I'd like to know if this is the right behaviour and, in that case, if
> something can be done to make it work as i want.
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Failover-reconnection-questions-tp3826592p3826592.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
http://fusesource.com
http://blog.garytully.com

Mime
View raw message