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 void
onDelivery(org.apache.qpid.proton.engine.Event event)
void
onLinkLocalOpen(org.apache.qpid.proton.engine.Event evt)
void
onLinkRemoteOpen(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:
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
-
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
-
-