activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From PedroRP <pedro.rami...@techonrails.com>
Subject Re: ActiveMQ HA on failover topic mode
Date Mon, 10 Dec 2018 09:51:34 GMT
Hi Tim!

My sender app is sending text messages with the text: "Message (sequence)".
The sender's log is showing the message after send it. This is the log:

Message 6291
Message 6292
Message 6293
Message 6294
Message 6295
2018-12-10 10:37:43.175  WARN 8732 --- [.45:61626@55241]
o.a.a.t.failover.FailoverTransport       : Transport
(tcp://172.18.13.45:61626) failed , attempting to automatically reconnect:
{}

java.io.EOFException: null
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
~[na:1.8.0_181]
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
~[activemq-all-5.15.0.jar:5.15.0]
	at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]

2018-12-10 10:37:50.567  INFO 8732 --- [ActiveMQ Task-1]
o.a.a.t.failover.FailoverTransport       : Successfully reconnected to
tcp://172.18.13.45:61616
Message 6296
Message 6297
Message 6298
Message 6299

The consumer's log is the following:

TopicMessageConsumer Received message [ Message 6292 ]
TopicMessageConsumer Received message [ Message 6293 ]
TopicMessageConsumer Received message [ Message 6294 ]
TopicMessageConsumer Received message [ Message 6295 ]
2018-12-10 10:37:43.175  WARN 6360 --- [.45:61626@55240]
o.a.a.t.failover.FailoverTransport       : Transport
(tcp://172.18.13.45:61626) failed , attempting to automatically reconnect:
{}

java.io.EOFException: null
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
~[na:1.8.0_181]
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
~[activemq-all-5.15.0.jar:5.15.0]
	at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]

2018-12-10 10:37:43.175  WARN 6360 --- [.45:61626@55242]
o.a.a.t.failover.FailoverTransport       : Transport
(tcp://172.18.13.45:61626) failed , attempting to automatically reconnect:
{}

java.io.EOFException: null
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
~[na:1.8.0_181]
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)
~[activemq-all-5.15.0.jar:5.15.0]
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
~[activemq-all-5.15.0.jar:5.15.0]
	at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]

2018-12-10 10:37:50.533  INFO 6360 --- [ActiveMQ Task-6]
o.a.a.t.failover.FailoverTransport       : Successfully reconnected to
tcp://172.18.13.45:61616
2018-12-10 10:37:51.586  INFO 6360 --- [ActiveMQ Task-6]
o.a.a.t.failover.FailoverTransport       : Successfully reconnected to
tcp://172.18.13.45:61616
TopicMessageConsumer Received message [ Message 7290 ]
TopicMessageConsumer Received message [ Message 7291 ]
TopicMessageConsumer Received message [ Message 7292 ]
TopicMessageConsumer Received message [ Message 7293 ]

I'm killing the broker ungracefully (kill -9).

I test the app with async and sync sending. Both cases with the same result. 

The above logs are using the following url to connect to the brokers:

failover:(tcp://broker1:61616,tcp://broker2:61626)?jms.useAsyncSend=false&trackMessages=true&timeout=1

Thanks!



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Mime
View raw message