Module org.apache.qpid.protonj2.client

Package org.apache.qpid.protonj2.client.impl

Class ClientSenderLinkType<LinkType extends Link<LinkType>>

java.lang.Object

org.apache.qpid.protonj2.client.impl.ClientLinkType<LinkType,org.apache.qpid.protonj2.engine.Sender>

org.apache.qpid.protonj2.client.impl.ClientSenderLinkType<LinkType>

Type Parameters:

LinkType - The client sender link type being implemented.

All Implemented Interfaces:

AutoCloseable, Link<LinkType>

Direct Known Subclasses:

ClientSender, ClientStreamSender

public abstract class ClientSenderLinkType<LinkType extends Link<LinkType>>
extends ClientLinkType<LinkType,org.apache.qpid.protonj2.engine.Sender>

Base type for all the proton client sender types which provides a few extra APIs for the connection and session to use when managing senders.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.qpid.protonj2.engine.Sender	protonSender

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

Constructors

Modifier	Constructor	Description
protected	ClientSenderLinkType(ClientSession session, String linkId, LinkOptions<?> options, org.apache.qpid.protonj2.engine.Sender protonSender)

Method Summary

Modifier and Type	Method	Description
protected final org.apache.qpid.protonj2.engine.Sender	protonLink()

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, linkSpecificCleanupHandler, linkSpecificLocalCloseHandler, linkSpecificLocalOpenHandler, linkSpecificRemoteCloseHandler, linkSpecificRemoteOpenHandler, notClosedOrFailed, notClosedOrFailed, offeredCapabilities, openFuture, properties, recreateLinkForReconnect, self, session, source, target, waitForOpenToComplete

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

protonSender

protected org.apache.qpid.protonj2.engine.Sender protonSender

Constructor Details

ClientSenderLinkType

protected ClientSenderLinkType(ClientSession session,
 String linkId,
 LinkOptions<?> options,
 org.apache.qpid.protonj2.engine.Sender protonSender)

Method Details

protonLink

protected final org.apache.qpid.protonj2.engine.Sender protonLink()

Specified by:

protonLink in class ClientLinkType<LinkType extends Link<LinkType>,org.apache.qpid.protonj2.engine.Sender>