public class AmqpTransactionCoordinator extends AmqpAbstractReceiver
configuredCredit, current, recvBuffer
closeActions, closed, endpoint, opened, session
Constructor and Description |
---|
AmqpTransactionCoordinator(AmqpSession session,
org.apache.qpid.proton.engine.Receiver endpoint)
Creates a new Transaction coordinator used to manage AMQP transactions.
|
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.
|
commit, delivery, detach, flow, flow, getConfiguredReceiverCredit, rollback
addCloseAction, close, close, getEndpoint, getSession, isClosed, isOpened, open, sendToActiveMQ, sendToActiveMQ
public AmqpTransactionCoordinator(AmqpSession session, org.apache.qpid.proton.engine.Receiver endpoint)
session
- the AmqpSession under which the coordinator was created.receiver
- the AMQP receiver link endpoint for this coordinator.protected void processDelivery(org.apache.qpid.proton.engine.Delivery delivery, org.fusesource.hawtbuf.Buffer deliveryBytes) throws Exception
processDelivery
in class AmqpAbstractReceiver
Exception
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
AmqpLink
destination
- the ActiveMQDestination that this link services.public void enlist(AmqpSession session)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.