[ https://issues.apache.org/activemq/browse/AMQ-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dejan Bosanac reassigned AMQ-2280: ---------------------------------- Assignee: Dejan Bosanac > stomp: Transport failed: java.io.IOException: Unexpected error occured > ---------------------------------------------------------------------- > > Key: AMQ-2280 > URL: https://issues.apache.org/activemq/browse/AMQ-2280 > Project: ActiveMQ > Issue Type: Bug > Components: Broker, Connector > Affects Versions: 5.3.0 > Environment: linux 2.6.26.8, Fedora Core 8 > java version "1.6.0_11" > Java(TM) SE Runtime Environment (build 1.6.0_11-b03) > Java HotSpot(TM) Client VM (build 11.0-b16, mixed mode, sharing) > apache-activemq-5.3-SNAPSHOT-bin.gz Fri May 29 06:12:47 GMT+00:00 2009 34977374 > Reporter: Aleksandar Ivanisevic > Assignee: Dejan Bosanac > Attachments: AMQ-2280.patch > > > 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 -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.