activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jzhang1 <jian.zh...@etrade.com>
Subject Re: Messages rollback
Date Fri, 13 Feb 2009 22:12:05 GMT

Thanks very much for AMQ CPP.  Our legacy system using the stomp library from
http://stomp.codehaus.org and write stomp frame to socket directly. 

The impls of commit and abort  are "COMMIT" and "ABORT" in the stomp frame
header. 

With regards to "ABORT",  the message acknowledge are abort and MQ broker
still keep this message. 
We expect on the next call of stomp_read, MQ broker deliver this pending
messages. However it does not unless reconnect and subscribe to the queue.
Is there any header attribute or configuration to let pending messages
redeliver on the next call stomp_read ? 






Dave Stanley wrote:
> 
> Yes - it looks like there was a bug fixed in the transaction support [1]
> so
> you would need the 2.2 release [2] of the C++ API for the transacted
> session
> capabilities.
> 
> [1] http://issues.apache.org/activemq/browse/AMQCPP-174
> [2] http://activemq.apache.org/cms/activemq-cpp-22-release.html
> 
> Regards
> /Dave
> 
> On Thu, Feb 12, 2009 at 12:07 PM, jzhang1 <jian.zhang@etrade.com> wrote:
> 
>>
>> Thanks very much for the information.  For the C/C++ sender and receiver,
>> does stomp provide the similar functionality as JMS session ?
>>
>>
>>
>>
>> Dave Stanley wrote:
>> >
>> > You can created a transacted jms session and either commit() or
>> rollback()
>> > that session. See:
>> >
>> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java?view=markup
>> >
>> > Regards
>> > /Dave
>> >
>> > On Wed, Feb 11, 2009 at 8:45 PM, jzhang1 <jian.zhang@etrade.com> wrote:
>> >
>> >>
>> >> ActiveMQ guru,
>> >>
>> >> I am curious whether ActiveMQ broker provide backout
>> >>
>> >> all enqueue and dequeue functions calls that have occurred since the
>> last
>> >> syncpoint are to be backed out. Messages put as part of a unit of work
>> >> are
>> >> deleted; messages retrieved as part of a unit of work are reinstated
>> on
>> >> the
>> >> queue.
>> >>
>> >> Thanks
>> >>
>> >> --
>> >> View this message in context:
>> >> http://www.nabble.com/Messages-rollback-tp21968419p21968419.html
>> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>> >>
>> >>
>> >
>> >
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Messages-rollback-tp21968419p21980374.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
> 
> 

-- 
View this message in context: http://www.nabble.com/Messages-rollback-tp21968419p22005863.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message