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 voidonDelivery(org.apache.qpid.proton.engine.Event event)voidonLinkFinal(org.apache.qpid.proton.engine.Event event)voidonLinkFlow(org.apache.qpid.proton.engine.Event event)voidonLinkLocalOpen(org.apache.qpid.proton.engine.Event event)voidonLinkRemoteOpen(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:
onLinkLocalOpenin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onLinkLocalOpenin classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkRemoteOpen
public void onLinkRemoteOpen(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkRemoteOpenin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onLinkRemoteOpenin classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkFinal
public void onLinkFinal(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkFinalin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onLinkFinalin classorg.apache.qpid.proton.engine.BaseHandler
-
onDelivery
public void onDelivery(org.apache.qpid.proton.engine.Event event)
- Specified by:
onDeliveryin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onDeliveryin classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkFlow
public void onLinkFlow(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkFlowin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onLinkFlowin classorg.apache.qpid.proton.engine.BaseHandler
-
-