activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Failover problem with ConsumerTool and JDBC Master-SLAVE
Date Sat, 03 Mar 2007 09:24:57 GMT
Are you sure you're using the failover: url on the consumer?

On 3/2/07, Matías Cobiella <matiascobiella@yahoo.com> wrote:
>
> 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.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message