Class ReceiveLinkHandler
- java.lang.Object
-
- org.apache.qpid.proton.engine.BaseHandler
-
- com.microsoft.azure.servicebus.amqp.BaseLinkHandler
-
- com.microsoft.azure.servicebus.amqp.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(IAmqpReceiver receiver)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonDelivery(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.servicebus.amqp.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, onLinkFinal, 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(IAmqpReceiver receiver)
-
-
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
-
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
-
-