ActiveMQ
  1. ActiveMQ
  2. AMQ-2280

stomp: Transport failed: java.io.IOException: Unexpected error occured

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: 5.3.0
    • Fix Version/s: 5.3.0
    • Component/s: Broker, Connector
    • Labels:
      None
    • Environment:

      Description

      This does not happen in 5.2.0, only in 5.3..SNAPSHOT

      I'm getting the above exception with the following STOMP session

      > telnet localhost 61613
      Trying 127.0.0.1...
      Connected to localhost.
      Escape character is '^]'.
      CONNECT
      passcode:password
      login:login

      ^@
      CONNECTED
      session:ID:alex-60773-1244124360289-2:2

      SUBSCRIBE
      activemq.prefetchSize:1
      ack:client
      destination:/queue/COMMAND.HOST.alex
      activemq.exclusive:true

      ^@
      BEGIN
      destination:/queue/COMMANDREPLY.HOST.alex
      transaction:ID:alex-58262-1244123488785-2:1-1
      persistent:true

      ^@
      SEND
      destination:/queue/COMMANDREPLY.HOST.alex
      transaction:ID:alex-58262-1244123488785-2:1-1
      receipt:ID:alex-58262-1244123488785-2:1-2
      persistent:true

      replytext
      ^@
      RECEIPT
      receipt-id:ID:alex-58262-1244123488785-2:1-2

      COMMIT
      destination:/queue/COMMANDREPLY.HOST.alex
      transaction:ID:alex-58262-1244123488785-2:1-1

      ^@
      Connection closed by foreign host.

      at this point AMQ closses the TCP connection and I see the following in the log (DEBUG root log level):

      DEBUG TransportConnection - Setting up new connection: /127.0.0.1:44692
      DEBUG AMQPersistenceAdapter - dataFilesInProgress.values: (0) []
      DEBUG AMQPersistenceAdapter - lastDataFile: 1
      DEBUG AsyncDataManager - lastFileId=0, purgeList: (0) []
      DEBUG AbstractRegion - localhost adding consumer: ID:alex-60773-1244124360289-2:2:-1:1 for destination: queue://COMMAND.HOST.alex
      DEBUG AMQPersistenceAdapter - Checkpoint started.
      DEBUG AMQPersistenceAdapter - Checkpoint done.
      DEBUG AMQPersistenceAdapter - Checkpoint started.
      DEBUG AMQPersistenceAdapter - Checkpoint done.
      DEBUG AMQPersistenceAdapter - dataFilesInProgress.values: (0) []
      DEBUG AMQPersistenceAdapter - lastDataFile: 1
      DEBUG AsyncDataManager - lastFileId=0, purgeList: (0) []
      DEBUG AMQPersistenceAdapter - Checkpoint started.
      DEBUG AMQPersistenceAdapter - Checkpoint done.
      DEBUG AMQMessageStore - Journalled transacted message add for: ID:alex-60773-1244124360289-2:2:-1:1:1, at: offset = 10973, file = 1, size = 375, type = 1
      DEBUG AMQPersistenceAdapter - dataFilesInProgress.values: (0) []
      DEBUG AMQPersistenceAdapter - lastDataFile: 1
      DEBUG AsyncDataManager - lastFileId=0, purgeList: (0) []
      DEBUG AMQPersistenceAdapter - Checkpoint started.
      DEBUG AMQPersistenceAdapter - Checkpoint done.
      DEBUG Transport - Transport failed: java.io.IOException: Unexpected error occured
      java.io.IOException: Unexpected error occured
      at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:192)
      at java.lang.Thread.run(Thread.java:619)
      Caused by: java.util.NoSuchElementException
      at java.util.LinkedList.getFirst(LinkedList.java:109)
      at org.apache.activemq.transport.stomp.StompSubscription.onStompCommit(StompSubscription.java:130)
      at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommit(ProtocolConverter.java:337)
      at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:179)
      at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:67)
      at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
      at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
      at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
      ... 1 more
      DEBUG TransportConnection - Stopping connection: /127.0.0.1:44692
      DEBUG TcpTransport - Stopping transport tcp:///127.0.0.1:44692
      DEBUG TransportConnection - Stopped transport: /127.0.0.1:44692
      DEBUG TransportConnection - Cleaning up connection resources: /127.0.0.1:44692
      DEBUG AbstractRegion - localhost removing consumer: ID:alex-60773-1244124360289-2:2:-1:1 for destination: queue://COMMAND.HOST.alex
      DEBUG LocalTransaction - rollback: TX:ID:alex-60773-1244124360289-2:2:1 syncCount: 3
      DEBUG AMQMessageStore - Transacted message add rollback for: ID:alex-60773-1244124360289-2:2:-1:1:1, at: offset = 10973, file = 1, size = 375, type = 1
      DEBUG TransportConnection - Connection Stopped: /127.0.0.1:44692

      1. AMQ-2280.patch
        1 kB
        Giovani Seben

        Activity

        No work has yet been logged on this issue.

          People

          • Assignee:
            Dejan Bosanac
            Reporter:
            Aleksandar Ivanisevic
          • Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development