public class AmqpConnectionBuilder extends AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
endpoint, parent, request, requestTimeoutTask, resource, resourceInfo
Constructor and Description |
---|
AmqpConnectionBuilder(AmqpProvider parent,
JmsConnectionInfo 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.
|
void |
buildResource(AsyncResult request)
Called to initiate the process of building the resource type that is
managed by this builder.
|
protected org.apache.qpid.proton.engine.Connection |
createEndpoint(JmsConnectionInfo resourceInfo)
Given the resource information provided create and configure the local endpoint
whose open phase is managed by this builder.
|
protected AmqpConnection |
createResource(AmqpProvider parent,
JmsConnectionInfo resourceInfo,
org.apache.qpid.proton.engine.Connection endpoint)
Create the managed resource instance.
|
protected long |
getRequestTimeout()
Returns the configured time before the open of the resource is considered
to have failed.
|
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.
|
getEndpoint, getOpenAbortException, getParent, getRequest, getResource, getResourceInfo, handleClosed, handleOpened, hasRemoteError, isOpenedEndpointValid, processDeliveryUpdates, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen
public AmqpConnectionBuilder(AmqpProvider parent, JmsConnectionInfo resourceInfo)
public void buildResource(AsyncResult request)
AmqpResourceBuilder
buildResource
in class AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
request
- The request that initiated the resource creation.protected org.apache.qpid.proton.engine.Connection createEndpoint(JmsConnectionInfo resourceInfo)
AmqpResourceBuilder
createEndpoint
in class AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
protected AmqpConnection createResource(AmqpProvider parent, JmsConnectionInfo resourceInfo, org.apache.qpid.proton.engine.Connection endpoint)
AmqpResourceBuilder
createResource
in class AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
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 void afterOpened()
AmqpResourceBuilder
afterOpened
in class AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
protected boolean isClosePending()
AmqpResourceBuilder
isClosePending
in class AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
protected long getRequestTimeout()
AmqpResourceBuilder
getRequestTimeout
in class AmqpResourceBuilder<AmqpConnection,AmqpProvider,JmsConnectionInfo,org.apache.qpid.proton.engine.Connection>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.