public class AmqpProducerBuilder extends AmqpResourceBuilder<AmqpProducer,AmqpSession,JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
endpoint, parent, request, requestTimeoutTask, resource, resourceInfo
Constructor and Description |
---|
AmqpProducerBuilder(AmqpSession parent,
JmsProducerInfo resourceInfo) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.qpid.proton.engine.Sender |
createEndpoint(JmsProducerInfo resourceInfo)
Given the resource information provided create and configure the local endpoint
whose open phase is managed by this builder.
|
protected AmqpProducer |
createResource(AmqpSession parent,
JmsProducerInfo resourceInfo,
org.apache.qpid.proton.engine.Sender endpoint)
Create the managed resource instance.
|
protected Exception |
getOpenAbortException()
When aborting the open operation, and there isn't an error condition,
provided by the peer, the returned exception will be used instead.
|
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, getParent, getRequest, getRequestTimeout, getResource, getResourceInfo, handleClosed, handleOpened, hasRemoteError, isOpenedEndpointValid, processDeliveryUpdates, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen
public AmqpProducerBuilder(AmqpSession parent, JmsProducerInfo resourceInfo)
protected org.apache.qpid.proton.engine.Sender createEndpoint(JmsProducerInfo resourceInfo)
AmqpResourceBuilder
createEndpoint
in class AmqpResourceBuilder<AmqpProducer,AmqpSession,JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
protected AmqpProducer createResource(AmqpSession parent, JmsProducerInfo resourceInfo, org.apache.qpid.proton.engine.Sender endpoint)
AmqpResourceBuilder
createResource
in class AmqpResourceBuilder<AmqpProducer,AmqpSession,JmsProducerInfo,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<AmqpProducer,AmqpSession,JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
protected Exception getOpenAbortException()
AmqpResourceBuilder
getOpenAbortException
in class AmqpResourceBuilder<AmqpProducer,AmqpSession,JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.