Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-850

EOFException when mq-client consumer uses failover transport

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • JBoss A-MQ 6.2
    • JBoss A-MQ 6.1
    • broker
    • Hide

      1. Start A-MQ
      2. Run java -jar mq-client.jar producer --user admin --password admin --brokerUrl failover://tcp://localhost:61616
      3. Run java -jar mq-client.jar consumer --user admin --password admin --brokerUrl failover://tcp://localhost:61616

      Show
      1. Start A-MQ 2. Run java -jar mq-client.jar producer --user admin --password admin --brokerUrl failover://tcp://localhost:61616 3. Run java -jar mq-client.jar consumer --user admin --password admin --brokerUrl failover://tcp://localhost:61616

      When consuming messages from A-MQ using mq-client and the failover transport, after the queue is empty mq-client throws an EOFException:

      [org.fusesource.mq.ConsumerThread] : Consumer thread finished
Consumed: 100 messages
[org.fusesource.mq.ActiveMQService] : Closed JMS connection
[org.apache.activemq.transport.failover.FailoverTransport] : Transport (tcp://localhost/127.0.0.1:61616@32778) failed, reason:  , attempting to automatically reconnect
java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258)
	at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
	at java.lang.Thread.run(Thread.java:745)
[org.apache.activemq.transport.failover.FailoverTransport] : Successfully reconnected to tcp://localhost:61616

      Broker log:

      2014-11-07 12:57:22,646 | WARN  | .0.1:32779@61616 | Transport  | ivemq.broker.TransportConnection  205 | 121 - org.apache.activemq.activemq-osgi - 5.9.0.redhat-610379 | 
Transport Connection to: tcp://127.0.0.1:32779 failed: java.io.EOFException

            Unassigned Unassigned
            rhn-support-iweiss Ingo Weiss
            Votes:
            1 Vote for this issue
            Watchers:
            6 Start watching this issue

              Created:
              Updated:
              Resolved: