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 Description AmqpTransactionCoordinator(AmqpSession session, org.apache.qpid.proton.engine.Receiver endpoint)
Creates a new Transaction coordinator used to manage AMQP transactions.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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
-
-
-
-
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.endpoint
- 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 classAmqpAbstractReceiver
- 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)
-
-