AMQ transaction rollback and commit

[ayache <ay...@zotix.co>]

Hi

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?

Thanks

Ayache


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

   private AuditWriter auditor;

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


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

        getNext().messageConsumed(context, messageReference);
    }

 }




--
View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-transaction-rollback-and-commit-tp4722998.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.