activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matías Cobiella <matiascobie...@yahoo.com>
Subject Failover problem with ConsumerTool and JDBC Master-SLAVE
Date Fri, 02 Mar 2007 22:33:08 GMT

Hi,

I have the following environment:

Two Brokers (localhost:11111 and localhost:22222) in a JDBC MASTER-SLAVE
(MySQL) configuration. The
ProducerTool and the ConsumerTool uses
failover:(tcp://localhost:11111,tcp://localhost:22222)

1) The BrokerA starts and becomes the MASTER.
2) The BrokerB starts and becomes the SLAVE.
3) The ConsumerTool is started and is listening on a queue of the MASTER.
4) The ProducerTool is started and it sends messages to the queue of the
MASTER and the ConsumerTool receive them.
5) MASTER is shutdown, then the SLAVE Becomes MASTER.
6) ProducerTool failover to the NEW MASTER and keeps sending messages.
7) But ConsumerTool crashes with the following error.

[INFO] FailoverTransport - -Successfully reconnected to
tcp://localhost:11111
Received: Message: 0 sent at: Fri Mar 02 19:15:20 GMT-03:00 ...
Received: Message: 1 sent at: Fri Mar 02 19:15:26 GMT-03:00 ...
Received: Message: 2 sent at: Fri Mar 02 19:15:31 GMT-03:00 ...
Received: Message: 3 sent at: Fri Mar 02 19:15:36 GMT-03:00 ...
Received: Message: 4 sent at: Fri Mar 02 19:15:41 GMT-03:00 ...
java.net.SocketException: Connection reset
	at java.net.SocketInputStream.read(SocketInputStream.java:168)
	at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:49)
	at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:56)
	at java.io.DataInputStream.readInt(DataInputStream.java:353)
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
	at java.lang.Thread.run(Thread.java:595)
[WARN] FailoverTransport - -Transport failed, attempting to automatically
reconnect due to: java.net.SocketException: Connection reset
<java.net.SocketException: Connection reset>


Does anybody knows why the ConsumerTool doesn't failover to the new MASTER?

I'm using the 4.2 SNAPSHOP.

Thanks in advance.

Matías.
-- 
View this message in context: http://www.nabble.com/Failover-problem-with-ConsumerTool-and-JDBC-Master-SLAVE-tf3336396s2354.html#a9278795
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


Mime
View raw message