Hi,
I am testing JDBC Master/Slave failover as described here:
http://www.activemq.org/site/jdbc-master-slave.html.
The setup works but I noticed there can be lost messages during the
failover.
My setup is the following:
* ActiveMQ 4.1.0 (linux distribution), ran wih the wrapper.
* Postgresql 8.1.5
* 2 machines are configured with activemq and point to the same database.
I use the ConsumerTool and the ProducerTool provided in the example
directory.
Here is the way they are launched:
Producer: ant -Dmax=6000 -DsleepTime=50 -Dtopic=false
-Dsubject=org.apache.activemq.spring.Test.spring
"-Durl=failover:(tcp://localhost:61616,tcp://xeon:61616)" producer
Output on the producer:
.. many lines
[java] Sending message: Message: 540 sent at: Thu Jan 25 15:41:08 CET
2007...
[java] Sending message: Message: 541 sent at: Thu Jan 25 15:41:08 CET
2007...
[java] 15:41:08 INFO Transport failed, attempting to automatically
reconnect due to: java.io.EOFException
[java] java.io.EOFException
[java] at java.io.DataInputStream.readInt(DataInputStream.java:375)
[java] at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
[java] at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
[java] at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
[java] at java.lang.Thread.run(Thread.java:619)
[java] Sending message: Message: 542 sent at: Thu Jan 25 15:41:08 CET
2007...
... many lines
Output on the consumer
... many lines
[java] Received: Message: 538 sent at: Thu Jan 25 15:41:08 CET 2007...
[java] Received: Message: 539 sent at: Thu Jan 25 15:41:08 CET 2007...
[java] Received: Message: 540 sent at: Thu Jan 25 15:41:08 CET 2007...
[java] 15:41:08 INFO Transport failed, attempting to automatically
reconnect due to: java.io.EOFException
[java] java.io.EOFException
[java] at java.io.DataInputStream.readInt(DataInputStream.java:375)
[java] at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
[java] at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
[java] at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
[java] at java.lang.Thread.run(Thread.java:619)
[java] Received: Message: 542 sent at: Thu Jan 25 15:41:08 CET 2007...
[java] Received: Message: 543 sent at: Thu Jan 25 15:41:08 CET 2007...
... many lines
It is clear from this output that message 541 is not seen by the consumer,
although it is sent (or should be) by the producer.
Thanks for any help on this.
Bernard.
--
View this message in context:
http://www.nabble.com/Message-lost-during-failover-tf3112451.html#a8623083
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
