Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Message-ID: <1542325722.1244124830931.JavaMail.jira@brutus>
Date: Thu, 4 Jun 2009 07:13:50 -0700 (PDT)
From: "Aleksandar Ivanisevic (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Created: (AMQ-2280) stomp: Transport failed:
 java.io.IOException: Unexpected error occured
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit

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


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.