[AMQ-2280] stomp: Transport failed: java.io.IOException: Unexpected error occured

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

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

• Assignee: Dejan Bosanac
• Reporter: Aleksandar Ivanisevic
• Created: 04/Jun/09 14:12
• Updated: 07/Aug/09 09:20
• Resolved: 07/Aug/09 09:20

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