public class AmqpConsumerBuilder extends AmqpResourceBuilder<AmqpConsumer,AmqpSession,JmsConsumerInfo,org.apache.qpid.proton.engine.Receiver>
endpoint, parent, request, requestTimeoutTask, resource, resourceInfo
Constructor and Description |
---|
AmqpConsumerBuilder(AmqpSession parent,
JmsConsumerInfo consumerInfo) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.qpid.proton.engine.Receiver |
createEndpoint(JmsConsumerInfo resourceInfo)
Given the resource information provided create and configure the local endpoint
whose open phase is managed by this builder.
|
protected AmqpConsumer |
createResource(AmqpSession parent,
JmsConsumerInfo resourceInfo,
org.apache.qpid.proton.engine.Receiver 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 AmqpConsumerBuilder(AmqpSession parent, JmsConsumerInfo consumerInfo)
protected org.apache.qpid.proton.engine.Receiver createEndpoint(JmsConsumerInfo resourceInfo)
AmqpResourceBuilder
createEndpoint
in class AmqpResourceBuilder<AmqpConsumer,AmqpSession,JmsConsumerInfo,org.apache.qpid.proton.engine.Receiver>
protected AmqpConsumer createResource(AmqpSession parent, JmsConsumerInfo resourceInfo, org.apache.qpid.proton.engine.Receiver endpoint)
AmqpResourceBuilder
createResource
in class AmqpResourceBuilder<AmqpConsumer,AmqpSession,JmsConsumerInfo,org.apache.qpid.proton.engine.Receiver>
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 Exception getOpenAbortException()
AmqpResourceBuilder
getOpenAbortException
in class AmqpResourceBuilder<AmqpConsumer,AmqpSession,JmsConsumerInfo,org.apache.qpid.proton.engine.Receiver>
protected boolean isClosePending()
AmqpResourceBuilder
isClosePending
in class AmqpResourceBuilder<AmqpConsumer,AmqpSession,JmsConsumerInfo,org.apache.qpid.proton.engine.Receiver>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.