public class AmqpTransactionCoordinator extends AmqpAbstractResource<JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
closeRequest, closeTimeoutTask
Constructor and Description |
---|
AmqpTransactionCoordinator(JmsSessionInfo resourceInfo,
org.apache.qpid.proton.engine.Sender endpoint,
AmqpResourceParent parent) |
Modifier and Type | Method and Description |
---|---|
void |
declare(JmsTransactionId txId,
AsyncResult request) |
void |
discharge(JmsTransactionId txId,
AsyncResult request,
boolean commit) |
void |
processDeliveryUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Delivery related event has been triggered
for the given endpoint.
|
void |
remotelyClosed(AmqpProvider provider) |
close, closeOrDetachEndpoint, getEndpoint, getLocalState, getParent, getRemoteState, getResourceInfo, isAwaitingClose, isClosed, isOpen, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen, resourceClosed
public AmqpTransactionCoordinator(JmsSessionInfo resourceInfo, org.apache.qpid.proton.engine.Sender endpoint, AmqpResourceParent parent)
public void processDeliveryUpdates(AmqpProvider provider) throws IOException
AmqpEventSink
processDeliveryUpdates
in interface AmqpEventSink
processDeliveryUpdates
in class AmqpAbstractResource<JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.public void declare(JmsTransactionId txId, AsyncResult request) throws Exception
Exception
public void discharge(JmsTransactionId txId, AsyncResult request, boolean commit) throws Exception
Exception
public void remotelyClosed(AmqpProvider provider)
remotelyClosed
in class AmqpAbstractResource<JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.