activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ayache <>
Subject AMQ transaction rollback and commit
Date Mon, 06 Mar 2017 15:19:07 GMT

I have written AMQ plugin - see bellow a snippet. I am overriding the *send*
and *messageConsumed* methods. Whenever a message is consumed the client
will either send a *commit* for successfully downloading the message or
*rollback* when it is failed. The *messageConsumed* gets invoked for either
cases and for each case there is some logic needs to be run. Is there a way
of finding out from the *context* or *MessageReference* weither the client
has commited the transation or rolled back?



 * Message AuditWriter Interceptor. It audits message into Cassandra
public final class MessageAuditorPlugin extends BrokerPluginSupport {

   private AuditWriter auditor;

    public void send(final ProducerBrokerExchange producerExchange, final
Message message) throws Exception {
      //some logic....
     // call super
      super.send(producerExchange, message);

    public void messageConsumed(final ConnectionContext context, final
MessageReference messageReference)  {
       // some logic....

        getNext().messageConsumed(context, messageReference);


View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message