org.apache.activemq.transport.amqp.protocol

Class AmqpTransactionCoordinator

java.lang.Object

org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink<org.apache.qpid.proton.engine.Receiver>

org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver

org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator

All Implemented Interfaces:

AmqpLink, AmqpResource

public class AmqpTransactionCoordinator
extends AmqpAbstractReceiver

Implements the AMQP Transaction Coordinator support to manage local transactions between an AMQP client and the broker.

Field Summary

Fields inherited from class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver

configuredCredit, current, recvBuffer

Fields inherited from class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink

closeActions, closed, endpoint, opened, session

Constructor Summary

Constructors

Constructor and Description
AmqpTransactionCoordinator(AmqpSession session, org.apache.qpid.proton.engine.Receiver endpoint) Creates a new Transaction coordinator used to manage AMQP transactions.

Method Summary

Modifier and Type	Method and Description
void	enlist(AmqpSession session)
ActiveMQDestination	getDestination()
protected void	processDelivery(org.apache.qpid.proton.engine.Delivery delivery, org.fusesource.hawtbuf.Buffer deliveryBytes)
void	setDestination(ActiveMQDestination destination) Sets the ActiveMQDestination that this link will be servicing.

Methods inherited from class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver

commit, delivery, detach, flow, flow, getConfiguredReceiverCredit, rollback

Methods inherited from class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink

addCloseAction, close, close, getEndpoint, getSession, isClosed, isOpened, open, sendToActiveMQ, sendToActiveMQ

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpTransactionCoordinator

public AmqpTransactionCoordinator(AmqpSession session,
                                  org.apache.qpid.proton.engine.Receiver endpoint)

Creates a new Transaction coordinator used to manage AMQP transactions.

Parameters:

session - the AmqpSession under which the coordinator was created.

receiver - the AMQP receiver link endpoint for this coordinator.

Method Detail

processDelivery

protected void processDelivery(org.apache.qpid.proton.engine.Delivery delivery,
                               org.fusesource.hawtbuf.Buffer deliveryBytes)
                        throws Exception

Specified by:

processDelivery in class AmqpAbstractReceiver

Throws:

Exception

getDestination

public ActiveMQDestination getDestination()

Returns:

the ActiveMQDestination that this link is servicing.

setDestination

public void setDestination(ActiveMQDestination destination)

Description copied from interface: AmqpLink

Sets the ActiveMQDestination that this link will be servicing.

Parameters:

destination - the ActiveMQDestination that this link services.

enlist

public void enlist(AmqpSession session)