[
https://issues.apache.org/activemq/browse/AMQ-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=53520#action_53520
]
Aleksandar Ivanisevic commented on AMQ-2280:
--------------------------------------------
Just to confirm that I have split the sending and receiving part of my client
into separate connections and that appears to have "fixed" the problem.
I still don't see anything both in the STOMP spec and common sense that would
be against mixing transacted and non-transacted statements in one connection,
so IMO this is a bug in AMQ STOMP, not in my usage (if we don't count sending a
destination in BEGIN frame which is clearly an error).
> 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.
