public class AmqpTemporaryDestinationBuilder extends AmqpResourceBuilder<AmqpTemporaryDestination,AmqpSession,JmsTemporaryDestination,org.apache.qpid.proton.engine.Sender>
endpoint, parent, request, requestTimeoutTask, resource, resourceInfo
Constructor and Description |
---|
AmqpTemporaryDestinationBuilder(AmqpSession parent,
JmsTemporaryDestination resourceInfo) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterOpened()
Called once an endpoint has been opened and validated to give the subclasses a
place to perform any follow-on processing or setup steps before the operation
is deemed to have been completed and success is signaled.
|
protected org.apache.qpid.proton.engine.Sender |
createEndpoint(JmsTemporaryDestination resourceInfo)
Given the resource information provided create and configure the local endpoint
whose open phase is managed by this builder.
|
protected AmqpTemporaryDestination |
createResource(AmqpSession parent,
JmsTemporaryDestination 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.
|
buildResource, getEndpoint, getOpenAbortException, getParent, getRequest, getRequestTimeout, getResource, getResourceInfo, handleClosed, handleOpened, hasRemoteError, isOpenedEndpointValid, processDeliveryUpdates, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen
public AmqpTemporaryDestinationBuilder(AmqpSession parent, JmsTemporaryDestination resourceInfo)
protected org.apache.qpid.proton.engine.Sender createEndpoint(JmsTemporaryDestination resourceInfo)
AmqpResourceBuilder
createEndpoint
in class AmqpResourceBuilder<AmqpTemporaryDestination,AmqpSession,JmsTemporaryDestination,org.apache.qpid.proton.engine.Sender>
protected AmqpTemporaryDestination createResource(AmqpSession parent, JmsTemporaryDestination resourceInfo, org.apache.qpid.proton.engine.Sender endpoint)
AmqpResourceBuilder
createResource
in class AmqpResourceBuilder<AmqpTemporaryDestination,AmqpSession,JmsTemporaryDestination,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<AmqpTemporaryDestination,AmqpSession,JmsTemporaryDestination,org.apache.qpid.proton.engine.Sender>
protected void afterOpened()
AmqpResourceBuilder
afterOpened
in class AmqpResourceBuilder<AmqpTemporaryDestination,AmqpSession,JmsTemporaryDestination,org.apache.qpid.proton.engine.Sender>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.