org.apache.qpid.server.txn
Interface TransactionalContext

All Known Implementing Classes:

LocalTransactionalContext, NonTransactionalContext

public interface TransactionalContext

Author:

Robert Greig ([email protected])

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()

Method Detail

beginTranIfNecessary

void beginTranIfNecessary()
                          throws AMQException

Throws:

AMQException

commit

void commit()
            throws AMQException

Throws:

AMQException

rollback

void rollback()
              throws AMQException

Throws:

AMQException

deliver

void deliver(AMQMessage message,
             AMQQueue queue)
             throws AMQException

Throws:

AMQException

acknowledgeMessage

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

Throws:

AMQException

messageFullyReceived

void messageFullyReceived(boolean persistent)
                          throws AMQException

Throws:

AMQException

messageProcessed

void messageProcessed(AMQProtocolSession protocolSession)
                      throws AMQException

Throws:

AMQException

getStoreContext

StoreContext getStoreContext()