Class BaseLinkHandler
- java.lang.Object
-
- org.apache.qpid.proton.engine.BaseHandler
-
- com.microsoft.azure.eventhubs.impl.BaseLinkHandler
-
- All Implemented Interfaces:
org.apache.qpid.proton.engine.CoreHandler
,org.apache.qpid.proton.engine.Handler
- Direct Known Subclasses:
ReceiveLinkHandler
,SendLinkHandler
public class BaseLinkHandler extends org.apache.qpid.proton.engine.BaseHandler
-
-
Field Summary
Fields Modifier and Type Field Description protected static org.slf4j.Logger
TRACE_LOGGER
-
Constructor Summary
Constructors Constructor Description BaseLinkHandler(AmqpLink amqpLink, String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onLinkLocalClose(org.apache.qpid.proton.engine.Event event)
void
onLinkRemoteClose(org.apache.qpid.proton.engine.Event event)
void
onLinkRemoteDetach(org.apache.qpid.proton.engine.Event event)
void
processOnClose(org.apache.qpid.proton.engine.Link link, Exception exception)
void
processOnClose(org.apache.qpid.proton.engine.Link link, org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
-
Methods inherited from class org.apache.qpid.proton.engine.BaseHandler
add, children, getHandler, getHandler, handle, onConnectionBound, onConnectionFinal, onConnectionInit, onConnectionLocalClose, onConnectionLocalOpen, onConnectionRemoteClose, onConnectionRemoteOpen, onConnectionUnbound, onDelivery, onLinkFinal, onLinkFlow, onLinkInit, onLinkLocalDetach, onLinkLocalOpen, onLinkRemoteOpen, 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
-
-
-
-
Method Detail
-
onLinkLocalClose
public void onLinkLocalClose(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkLocalClose
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkLocalClose
in classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkRemoteClose
public void onLinkRemoteClose(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkRemoteClose
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkRemoteClose
in classorg.apache.qpid.proton.engine.BaseHandler
-
onLinkRemoteDetach
public void onLinkRemoteDetach(org.apache.qpid.proton.engine.Event event)
- Specified by:
onLinkRemoteDetach
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onLinkRemoteDetach
in classorg.apache.qpid.proton.engine.BaseHandler
-
processOnClose
public void processOnClose(org.apache.qpid.proton.engine.Link link, org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
-
processOnClose
public void processOnClose(org.apache.qpid.proton.engine.Link link, Exception exception)
-
-