Class SendLinkHandler
- java.lang.Object
-
- org.apache.qpid.proton.engine.BaseHandler
-
- com.microsoft.azure.eventhubs.impl.BaseLinkHandler
-
- com.microsoft.azure.eventhubs.impl.SendLinkHandler
-
- All Implemented Interfaces:
org.apache.qpid.proton.engine.CoreHandler
,org.apache.qpid.proton.engine.Handler
public class SendLinkHandler extends BaseLinkHandler
-
-
Constructor Summary
Constructors Constructor Description SendLinkHandler(AmqpSender sender, String senderName, ScheduledExecutorService executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onDelivery(org.apache.qpid.proton.engine.Event event)
void
onLinkFinal(org.apache.qpid.proton.engine.Event event)
void
onLinkFlow(org.apache.qpid.proton.engine.Event event)
void
onLinkLocalOpen(org.apache.qpid.proton.engine.Event event)
void
onLinkRemoteOpen(org.apache.qpid.proton.engine.Event event)
-
Methods inherited from class com.microsoft.azure.eventhubs.impl.BaseLinkHandler
onLinkLocalClose, onLinkRemoteClose, onLinkRemoteDetach, processOnClose, processOnClose
-
Methods inherited from class org.apache.qpid.proton.engine.BaseHandler
add, children, getHandler, getHandler, handle, onConnectionBound, onConnectionFinal, onConnectionInit, onConnectionLocalClose, onConnectionLocalOpen, onConnectionRemoteClose, onConnectionRemoteOpen, onConnectionUnbound, onLinkInit, onLinkLocalDetach, onReactorFinal, onReactorInit, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionFinal, onSessionInit, onSessionLocalClose, onSessionLocalOpen, onSessionRemoteClose, onSessionRemoteOpen, onTimerTask, onTransport, onTransportClosed, onTransportError, onTransportHeadClosed, onTransportTailClosed, onUnhandled, setHandler, setHandler
-
-
-
-
Constructor Detail
-
SendLinkHandler
public SendLinkHandler(AmqpSender sender, String senderName, ScheduledExecutorService executor)
-
-
Method Detail
-
onLinkLocalOpen
public void onLinkLocalOpen(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkLocalOpen
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkLocalOpen
in classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkRemoteOpen
public void onLinkRemoteOpen(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkRemoteOpen
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkRemoteOpen
in classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkFinal
public void onLinkFinal(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkFinal
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkFinal
in classorg.apache.qpid.proton.engine.BaseHandler
-
onDelivery
public void onDelivery(org.apache.qpid.proton.engine.Event event)
- Specified by:
onDelivery
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onDelivery
in classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkFlow
public void onLinkFlow(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkFlow
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkFlow
in classorg.apache.qpid.proton.engine.BaseHandler
-
-