Class ReceiveLinkHandler
- java.lang.Object
-
- org.apache.qpid.proton.engine.BaseHandler
-
- com.microsoft.azure.eventhubs.impl.BaseLinkHandler
-
- com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler
-
- All Implemented Interfaces:
org.apache.qpid.proton.engine.CoreHandler,org.apache.qpid.proton.engine.Handler
public final class ReceiveLinkHandler extends BaseLinkHandler
-
-
Constructor Summary
Constructors Constructor Description ReceiveLinkHandler(AmqpReceiver receiver, String receiverName, 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)voidonLinkLocalOpen(org.apache.qpid.proton.engine.Event evt)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, onLinkFlow, 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
-
ReceiveLinkHandler
public ReceiveLinkHandler(AmqpReceiver receiver, String receiverName, ScheduledExecutorService executor)
-
-
Method Detail
-
onLinkLocalOpen
public void onLinkLocalOpen(org.apache.qpid.proton.engine.Event evt)
- 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
-
-