You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by Brian McCallister <br...@pobox.com> on 2006/08/18 18:44:26 UTC
Fwd: [stomp-dev] messages are not redelivered in activemq-4.0.2
Begin forwarded message:
> From: Jeff Tupholme <je...@makemyshow.com>
> Date: August 18, 2006 9:17:17 AM PDT
> To: dev@stomp.codehaus.org
> Subject: [stomp-dev] messages are not redelivered in activemq-4.0.2
> Reply-To: dev@stomp.codehaus.org
>
>
> Hoping for some help in understanding STOMP semantics.
> incubator-activemq-4.0.2
> My test application sends two messages to queueA, starts a new
> connection which subscribes to queueA, then processes each
> message in its own transaction. When a transaction is aborted I
> expected its message to be redelivered but this doesn't happen.
> Opening a new connection and resubscribing picks up the aborted
> message but it is not marked as being redelivered.
> In the Java test code for ActiveMQ it appears that a message within a
> rolled-back transaction is redelivered to the session almost
> immediately (./incubator-activemq-4.0.2/src/test/java/org/apache/
> activemq/usecases/Trans actionRollbackOrderTest.java).
> I noticed that each time my program sends a message ACK ActiveMQ
> throws NullPointerException (see below).
> At this point I'm not sure how much functionality STOMP is intended to
> offer so I might be wrong to report this as a bug. Before I report
> another bug - Is it supposed to be possible to interleave transactions
> on a single connection?
>
> Thanks!
>
>
> Pseudo-code
> msg1 = receiver.NextMsg()
> msg1.Begin() -- begin transaction and acknowledge the message
> msg1.Abort() -- abort transaction
> msg2 = receiver.NextMsg()
> msg2.Begin() -- begin transaction and acknowledge the message
> msg2.Commit()
> msg3 = receiver.NextMsg() -- expecting msg1 to be redelivered
>
> STOMP Protocol Trace
> --------------------
> CONNECT
> user: usr
> passcode: password
> .
> CONNECTED
> session:ID:ubuntu-32784-1155902931062-3:163
> .
> SUBSCRIBE
> destination: /queue/queueA
> ack: client
> .
> MESSAGE
> destination:/queue/queueA
> type:null
> reply-to:null
> timestamp:1155915641587
> priority:0
> expires:0
> correlation-id:null
> message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:1
>
> 0
> .
> MESSAGE
> destination:/queue/queueA
> type:null
> reply-to:null
> timestamp:1155915641795
> priority:0
> expires:0
> correlation-id:null
> message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:2
>
> 1
> .
> BEGIN
> transaction: ba0c02205582f84dfffa90cf75fd2395
> .
> ACK
> message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:1
> transaction: ba0c02205582f84dfffa90cf75fd2395
> .
> ABORT
> transaction: ba0c02205582f84dfffa90cf75fd2395
> .
> BEGIN
> transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> .
> ACK
> message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:2
> transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> .
> COMMIT
> transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> .
> CONNECT
> user: usr
> passcode: password
> .
> CONNECTED
> session:ID:ubuntu-32784-1155902931062-3:163
> .
> SUBSCRIBE
> destination: /queue/queueA
> ack: client
> .
> MESSAGE
> destination:/queue/queueA
> type:null
> reply-to:null
> timestamp:1155915641587
> priority:0
> expires:0
> correlation-id:null
> message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:1
>
> 0
> .
> MESSAGE
> destination:/queue/queueA
> type:null
> reply-to:null
> timestamp:1155915641795
> priority:0
> expires:0
> correlation-id:null
> message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:2
>
> 1
> .
> BEGIN
> transaction: ba0c02205582f84dfffa90cf75fd2395
> .
> ACK
> message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:1
> transaction: ba0c02205582f84dfffa90cf75fd2395
> .
> ABORT
> transaction: ba0c02205582f84dfffa90cf75fd2395
> .
> BEGIN
> transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> .
> ACK
> message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:2
> transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> .
> COMMIT
> transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> .
>
> Java Exception stack trace
> --------------------------
> Async error occurred: java.lang.NullPointerException
> java.lang.NullPointerException
> at
> org.apache.activemq.broker.region.PrefetchSubscription.acknowledge
> (PrefetchS ubscription.java:122)
> at
> org.apache.activemq.broker.region.AbstractRegion.acknowledge
> (AbstractRegion. java:233)
> at org.apache.activemq.broker.region.RegionBroker.acknowledge
> (RegionBroker.java :362)
> at org.apache.activemq.broker.TransactionBroker.acknowledge
> (TransactionBroker.j ava:176)
> at org.apache.activemq.broker.BrokerFilter.acknowledge
> (BrokerFilter.java:65)
> at org.apache.activemq.broker.BrokerFilter.acknowledge
> (BrokerFilter.java:65)
> at org.apache.activemq.broker.MutableBrokerFilter.acknowledge
> (MutableBrokerFilt er.java:78)
> at
> org.apache.activemq.broker.AbstractConnection.processMessageAck
> (AbstractConn ection.java:382)
> at org.apache.activemq.command.MessageAck.visit
> (MessageAck.java:178)
> at org.apache.activemq.broker.AbstractConnection.service
> (AbstractConnection.jav a:226)
> at org.apache.activemq.broker.TransportConnection$1.onCommand
> (TransportConnecti on.java:62)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand
> (ResponseCorrelato r.java:91)
> at org.apache.activemq.transport.TransportFilter.onCommand
> (TransportFilter.java :63)
> at org.apache.activemq.transport.InactivityMonitor.onCommand
> (InactivityMonitor. java:122)
> at
> org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveM
> Q(Stom pTransportFilter.java:69)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ
> (Protoco lConverter.java:111)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompAck
> (ProtocolCon verter.java:227)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad
> (Protocol Converter.java:133)
> at
> org.apache.activemq.transport.stomp.StompTransportFilter.onCommand
> (StompTran sportFilter.java:59)
> at org.apache.activemq.transport.TransportSupport.doConsume
> (TransportSupport.ja va:87)
> at org.apache.activemq.transport.tcp.TcpTransport.run
> (TcpTransport.java:127)
> at java.lang.Thread.run(Unknown Source)
> 2006-08-18 15:05:20,756 [127.0.0.1:57422] DEBUG Service
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe from this list please visit:
>
> http://xircles.codehaus.org/manage_email
>
Re: [stomp-dev] messages are not redelivered in activemq-4.0.2
Posted by James Strachan <ja...@gmail.com>.
I replied to this one on the Stomp list
http://www.nabble.com/Re%3A-messages-are-not-redelivered-in-activemq-4.0.2-p5902314.html
On 8/18/06, Brian McCallister <br...@pobox.com> wrote:
>
>
> Begin forwarded message:
>
> > From: Jeff Tupholme <je...@makemyshow.com>
> > Date: August 18, 2006 9:17:17 AM PDT
> > To: dev@stomp.codehaus.org
> > Subject: [stomp-dev] messages are not redelivered in activemq-4.0.2
> > Reply-To: dev@stomp.codehaus.org
> >
> >
> > Hoping for some help in understanding STOMP semantics.
> > incubator-activemq-4.0.2
> > My test application sends two messages to queueA, starts a new
> > connection which subscribes to queueA, then processes each
> > message in its own transaction. When a transaction is aborted I
> > expected its message to be redelivered but this doesn't happen.
> > Opening a new connection and resubscribing picks up the aborted
> > message but it is not marked as being redelivered.
> > In the Java test code for ActiveMQ it appears that a message within a
> > rolled-back transaction is redelivered to the session almost
> > immediately (./incubator-activemq-4.0.2/src/test/java/org/apache/
> > activemq/usecases/Trans actionRollbackOrderTest.java).
> > I noticed that each time my program sends a message ACK ActiveMQ
> > throws NullPointerException (see below).
> > At this point I'm not sure how much functionality STOMP is intended to
> > offer so I might be wrong to report this as a bug. Before I report
> > another bug - Is it supposed to be possible to interleave transactions
> > on a single connection?
> >
> > Thanks!
> >
> >
> > Pseudo-code
> > msg1 = receiver.NextMsg()
> > msg1.Begin() -- begin transaction and acknowledge the message
> > msg1.Abort() -- abort transaction
> > msg2 = receiver.NextMsg()
> > msg2.Begin() -- begin transaction and acknowledge the message
> > msg2.Commit()
> > msg3 = receiver.NextMsg() -- expecting msg1 to be redelivered
> >
> > STOMP Protocol Trace
> > --------------------
> > CONNECT
> > user: usr
> > passcode: password
> > .
> > CONNECTED
> > session:ID:ubuntu-32784-1155902931062-3:163
> > .
> > SUBSCRIBE
> > destination: /queue/queueA
> > ack: client
> > .
> > MESSAGE
> > destination:/queue/queueA
> > type:null
> > reply-to:null
> > timestamp:1155915641587
> > priority:0
> > expires:0
> > correlation-id:null
> > message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:1
> >
> > 0
> > .
> > MESSAGE
> > destination:/queue/queueA
> > type:null
> > reply-to:null
> > timestamp:1155915641795
> > priority:0
> > expires:0
> > correlation-id:null
> > message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:2
> >
> > 1
> > .
> > BEGIN
> > transaction: ba0c02205582f84dfffa90cf75fd2395
> > .
> > ACK
> > message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:1
> > transaction: ba0c02205582f84dfffa90cf75fd2395
> > .
> > ABORT
> > transaction: ba0c02205582f84dfffa90cf75fd2395
> > .
> > BEGIN
> > transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> > .
> > ACK
> > message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:2
> > transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> > .
> > COMMIT
> > transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> > .
> > CONNECT
> > user: usr
> > passcode: password
> > .
> > CONNECTED
> > session:ID:ubuntu-32784-1155902931062-3:163
> > .
> > SUBSCRIBE
> > destination: /queue/queueA
> > ack: client
> > .
> > MESSAGE
> > destination:/queue/queueA
> > type:null
> > reply-to:null
> > timestamp:1155915641587
> > priority:0
> > expires:0
> > correlation-id:null
> > message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:1
> >
> > 0
> > .
> > MESSAGE
> > destination:/queue/queueA
> > type:null
> > reply-to:null
> > timestamp:1155915641795
> > priority:0
> > expires:0
> > correlation-id:null
> > message-id:ID:ubuntu-32784-1155902931062-3:160:-1:1:2
> >
> > 1
> > .
> > BEGIN
> > transaction: ba0c02205582f84dfffa90cf75fd2395
> > .
> > ACK
> > message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:1
> > transaction: ba0c02205582f84dfffa90cf75fd2395
> > .
> > ABORT
> > transaction: ba0c02205582f84dfffa90cf75fd2395
> > .
> > BEGIN
> > transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> > .
> > ACK
> > message-id: ID:ubuntu-32784-1155902931062-3:160:-1:1:2
> > transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> > .
> > COMMIT
> > transaction: 3d4bf8b18ca395e9aaa63a7853f3d3af
> > .
> >
> > Java Exception stack trace
> > --------------------------
> > Async error occurred: java.lang.NullPointerException
> > java.lang.NullPointerException
> > at
> > org.apache.activemq.broker.region.PrefetchSubscription.acknowledge
> > (PrefetchS ubscription.java:122)
> > at
> > org.apache.activemq.broker.region.AbstractRegion.acknowledge
> > (AbstractRegion. java:233)
> > at org.apache.activemq.broker.region.RegionBroker.acknowledge
> > (RegionBroker.java :362)
> > at org.apache.activemq.broker.TransactionBroker.acknowledge
> > (TransactionBroker.j ava:176)
> > at org.apache.activemq.broker.BrokerFilter.acknowledge
> > (BrokerFilter.java:65)
> > at org.apache.activemq.broker.BrokerFilter.acknowledge
> > (BrokerFilter.java:65)
> > at org.apache.activemq.broker.MutableBrokerFilter.acknowledge
> > (MutableBrokerFilt er.java:78)
> > at
> > org.apache.activemq.broker.AbstractConnection.processMessageAck
> > (AbstractConn ection.java:382)
> > at org.apache.activemq.command.MessageAck.visit
> > (MessageAck.java:178)
> > at org.apache.activemq.broker.AbstractConnection.service
> > (AbstractConnection.jav a:226)
> > at org.apache.activemq.broker.TransportConnection$1.onCommand
> > (TransportConnecti on.java:62)
> > at org.apache.activemq.transport.ResponseCorrelator.onCommand
> > (ResponseCorrelato r.java:91)
> > at org.apache.activemq.transport.TransportFilter.onCommand
> > (TransportFilter.java :63)
> > at org.apache.activemq.transport.InactivityMonitor.onCommand
> > (InactivityMonitor. java:122)
> > at
> > org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveM
> > Q(Stom pTransportFilter.java:69)
> > at
> > org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ
> > (Protoco lConverter.java:111)
> > at
> > org.apache.activemq.transport.stomp.ProtocolConverter.onStompAck
> > (ProtocolCon verter.java:227)
> > at
> > org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad
> > (Protocol Converter.java:133)
> > at
> > org.apache.activemq.transport.stomp.StompTransportFilter.onCommand
> > (StompTran sportFilter.java:59)
> > at org.apache.activemq.transport.TransportSupport.doConsume
> > (TransportSupport.ja va:87)
> > at org.apache.activemq.transport.tcp.TcpTransport.run
> > (TcpTransport.java:127)
> > at java.lang.Thread.run(Unknown Source)
> > 2006-08-18 15:05:20,756 [127.0.0.1:57422] DEBUG Service
> >
> >
> >
> > ---------------------------------------------------------------------
> > To unsubscribe from this list please visit:
> >
> > http://xircles.codehaus.org/manage_email
> >
>
>
--
James
-------
http://radio.weblogs.com/0112098/