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
