org.apache.qpid.server.txn
Class NonTransactionalContext

java.lang.Object
  org.apache.qpid.server.txn.NonTransactionalContext

All Implemented Interfaces:

TransactionalContext

public class NonTransactionalContext
extends java.lang.Object
implements TransactionalContext

Author:

Apache Software Foundation

Constructor Summary

NonTransactionalContext(MessageStore messageStore, StoreContext storeContext, AMQChannel channel, java.util.List<RequiredDeliveryException> returnMessages, java.util.Set<java.lang.Long> browsedAcks)

Method Summary

void	acknowledgeMessage(long deliveryTag, long lastDeliveryTag, boolean multiple, UnacknowledgedMessageMap unacknowledgedMessageMap)
void	beginTranIfNecessary()
void	commit()
void	deliver(AMQMessage message, AMQQueue queue)
StoreContext	getStoreContext()
void	messageFullyReceived(boolean persistent)
void	messageProcessed(AMQProtocolSession protocolSession)
void	rollback()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NonTransactionalContext

public NonTransactionalContext(MessageStore messageStore,
                               StoreContext storeContext,
                               AMQChannel channel,
                               java.util.List<RequiredDeliveryException> returnMessages,
                               java.util.Set<java.lang.Long> browsedAcks)

Method Detail

getStoreContext

public StoreContext getStoreContext()

Specified by:

getStoreContext in interface TransactionalContext

beginTranIfNecessary

public void beginTranIfNecessary()
                          throws AMQException

Specified by:

beginTranIfNecessary in interface TransactionalContext

Throws:

AMQException

commit

public void commit()
            throws AMQException

Specified by:

commit in interface TransactionalContext

Throws:

AMQException

rollback

public void rollback()
              throws AMQException

Specified by:

rollback in interface TransactionalContext

Throws:

AMQException

deliver

public void deliver(AMQMessage message,
                    AMQQueue queue)
             throws AMQException

Specified by:

deliver in interface TransactionalContext

Throws:

AMQException

acknowledgeMessage

public void acknowledgeMessage(long deliveryTag,
                               long lastDeliveryTag,
                               boolean multiple,
                               UnacknowledgedMessageMap unacknowledgedMessageMap)
                        throws AMQException

Specified by:

acknowledgeMessage in interface TransactionalContext

Throws:

AMQException

messageFullyReceived

public void messageFullyReceived(boolean persistent)
                          throws AMQException

Specified by:

messageFullyReceived in interface TransactionalContext

Throws:

AMQException

messageProcessed

public void messageProcessed(AMQProtocolSession protocolSession)
                      throws AMQException

Specified by:

messageProcessed in interface TransactionalContext

Throws:

AMQException