Class ClientReceiverLinkType<ReceiverType extends Link<ReceiverType>>
java.lang.Object
org.apache.qpid.protonj2.client.impl.ClientLinkType<ReceiverType,Receiver>
org.apache.qpid.protonj2.client.impl.ClientReceiverLinkType<ReceiverType>
- Type Parameters:
ReceiverType
- The client receiver type that is being implemented.
- All Implemented Interfaces:
AutoCloseable
,Link<ReceiverType>
- Direct Known Subclasses:
ClientReceiver
,ClientStreamReceiver
public abstract class ClientReceiverLinkType<ReceiverType extends Link<ReceiverType>>
extends ClientLinkType<ReceiverType,Receiver>
Base class for client link types that wrap a proton receiver to provide
delivery dispatch in some manner.
-
Field Summary
Modifier and TypeFieldDescriptionprotected ClientFuture<ReceiverType>
protected Future<?>
protected Receiver
Fields inherited from class org.apache.qpid.protonj2.client.impl.ClientLinkType
closed, CLOSED_UPDATER, closeFuture, executor, failureCause, linkId, linkRemotelyClosedHandler, openFuture, options, remoteSource, remoteTarget, session
-
Constructor Summary
ModifierConstructorDescriptionprotected
ClientReceiverLinkType
(ClientSession session, String linkId, LinkOptions<?> options, Receiver protonReceiver) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
handleDeliveryAborted
(IncomingDelivery delivery) protected abstract void
handleDeliveryRead
(IncomingDelivery delivery) protected void
protected void
handleReceiverCreditUpdated
(Receiver receiver) protected void
linkSpecificCleanupHandler
(ClientException failureCause) protected void
protected void
protected void
protected void
protected Receiver
protected abstract void
Methods inherited from class org.apache.qpid.protonj2.client.impl.ClientLinkType
address, checkClosedOrFailed, client, close, close, closeAsync, closeAsync, connection, desiredCapabilities, detach, detach, detachAsync, detachAsync, handleEngineShutdown, handleLocalCloseOrDetach, handleLocalOpen, handleParentEndpointClosed, handleRemoteCloseOrDetach, handleRemoteOpen, immediateLinkShutdown, notClosedOrFailed, notClosedOrFailed, offeredCapabilities, openFuture, properties, recreateLinkForReconnect, self, session, source, target, waitForOpenToComplete
-
Field Details
-
drainingFuture
-
drainingTimeout
-
protonReceiver
-
-
Constructor Details
-
ClientReceiverLinkType
protected ClientReceiverLinkType(ClientSession session, String linkId, LinkOptions<?> options, Receiver protonReceiver)
-
-
Method Details
-
protonLink
- Specified by:
protonLink
in classClientLinkType<ReceiverType extends Link<ReceiverType>,
Receiver>
-
replenishCreditIfNeeded
protected abstract void replenishCreditIfNeeded() -
handleDeliveryRead
-
handleDeliveryAborted
-
handleDeliveryStateRemotelyUpdated
-
handleReceiverCreditUpdated
-
linkSpecificLocalOpenHandler
protected void linkSpecificLocalOpenHandler()- Specified by:
linkSpecificLocalOpenHandler
in classClientLinkType<ReceiverType extends Link<ReceiverType>,
Receiver>
-
linkSpecificRemoteOpenHandler
protected void linkSpecificRemoteOpenHandler()- Specified by:
linkSpecificRemoteOpenHandler
in classClientLinkType<ReceiverType extends Link<ReceiverType>,
Receiver>
-
linkSpecificLocalCloseHandler
protected void linkSpecificLocalCloseHandler()- Specified by:
linkSpecificLocalCloseHandler
in classClientLinkType<ReceiverType extends Link<ReceiverType>,
Receiver>
-
linkSpecificRemoteCloseHandler
protected void linkSpecificRemoteCloseHandler()- Specified by:
linkSpecificRemoteCloseHandler
in classClientLinkType<ReceiverType extends Link<ReceiverType>,
Receiver>
-
linkSpecificCleanupHandler
- Specified by:
linkSpecificCleanupHandler
in classClientLinkType<ReceiverType extends Link<ReceiverType>,
Receiver>
-