public class AmqpTransactionCoordinatorBuilder extends AmqpResourceBuilder<AmqpTransactionCoordinator,AmqpTransactionContext,JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
endpoint, parent, request, requestTimeoutTask, resource, resourceInfo
Constructor and Description |
---|
AmqpTransactionCoordinatorBuilder(AmqpTransactionContext parent,
JmsSessionInfo resourceInfo) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.qpid.proton.engine.Sender |
createEndpoint(JmsSessionInfo resourceInfo)
Given the resource information provided create and configure the local endpoint
whose open phase is managed by this builder.
|
protected AmqpTransactionCoordinator |
createResource(AmqpTransactionContext parent,
JmsSessionInfo resourceInfo,
org.apache.qpid.proton.engine.Sender endpoint)
Create the managed resource instance.
|
protected boolean |
isClosePending()
If the resource was opened but its current state indicates a close is pending
then we do no need to proceed further into the resource creation process.
|
afterOpened, buildResource, getEndpoint, getOpenAbortException, getParent, getRequest, getRequestTimeout, getResource, getResourceInfo, handleClosed, handleOpened, hasRemoteError, isOpenedEndpointValid, processDeliveryUpdates, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen
public AmqpTransactionCoordinatorBuilder(AmqpTransactionContext parent, JmsSessionInfo resourceInfo)
protected org.apache.qpid.proton.engine.Sender createEndpoint(JmsSessionInfo resourceInfo)
AmqpResourceBuilder
createEndpoint
in class AmqpResourceBuilder<AmqpTransactionCoordinator,AmqpTransactionContext,JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
protected AmqpTransactionCoordinator createResource(AmqpTransactionContext parent, JmsSessionInfo resourceInfo, org.apache.qpid.proton.engine.Sender endpoint)
AmqpResourceBuilder
createResource
in class AmqpResourceBuilder<AmqpTransactionCoordinator,AmqpTransactionContext,JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
parent
- The parent of the newly created resource.resourceInfo
- The resource information used to configure the resource.endpoint
- The local endpoint for the managed resource to wrap.protected boolean isClosePending()
AmqpResourceBuilder
isClosePending
in class AmqpResourceBuilder<AmqpTransactionCoordinator,AmqpTransactionContext,JmsSessionInfo,org.apache.qpid.proton.engine.Sender>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.