Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-3809

Simple ActiveMQ consumer dies on failover

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 5.5.1
    • Fix Version/s: 5.6.0
    • Component/s: Broker, Transport
    • Labels:
      None
    • Environment:

      solaris, linux

      Description

      I have a simple consumer application which connects to the broker using failover url. The consumer uses Message listener to asynchronously listen to messages. Whenever i kill my primary broker, I get an EOF exception(which is expected), the consumer tries to connect to failover broker but before it could finish the reconnect, it shuts down.
      My simple producer connecting with the same failover url never dies and successfully connects to failover broker.

      What is going on here?

      Posting the snippet with which the consumer dies:-

      2012-04-17 06:45:25,771 WARN org.apache.activemq.transport.failover.FailoverTransport - Transport (host1/10.240.170.28:61616) failed to tcp://host1:61616 , attempting to automatically reconnect due to: java.io.EOFException
      2012-04-17 06:45:25,772 DEBUG org.apache.activemq.transport.failover.FailoverTransport - Transport failed with the following exception:
      java.io.EOFException
      at java.io.DataInputStream.readInt(DataInputStream.java:392)
      at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
      at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
      at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
      at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
      at java.lang.Thread.run(Thread.java:722)
      2012-04-17 06:45:25,774 DEBUG org.apache.activemq.transport.failover.FailoverTransport - urlList connectionList:[tcp://host2:61616, tcp://host1:61616], from: [tcp://host1:61616, tcp://host2:61616]
      2012-04-17 06:45:25,774 DEBUG org.apache.activemq.transport.failover.FailoverTransport - Attempting connect to: tcp://host2:61616
      20120417 06:45:25.776 EDT (Shutdown-ActiveMQConsumer) ActiveMQConsumer#stop INFO Stopping the consumer...
      2012-04-17 06:45:26,242 DEBUG org.apache.activemq.transport.failover.FailoverTransport - Stopped.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              xbhanu Bhanu

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment