Class ReactorHandler
- java.lang.Object
-
- org.apache.qpid.proton.engine.BaseHandler
-
- com.microsoft.azure.eventhubs.impl.ReactorHandler
-
- All Implemented Interfaces:
org.apache.qpid.proton.engine.CoreHandler,org.apache.qpid.proton.engine.Handler
public class ReactorHandler extends org.apache.qpid.proton.engine.BaseHandler
-
-
Constructor Summary
Constructors Constructor Description ReactorHandler(String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ReactorDispatchergetReactorDispatcher()voidonReactorFinal(org.apache.qpid.proton.engine.Event e)voidonReactorInit(org.apache.qpid.proton.engine.Event e)voidunsafeSetReactorDispatcher(ReactorDispatcher reactorDispatcher)-
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, onLinkLocalClose, onLinkLocalDetach, onLinkLocalOpen, onLinkRemoteClose, onLinkRemoteDetach, onLinkRemoteOpen, 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
-
ReactorHandler
public ReactorHandler(String name)
-
-
Method Detail
-
getReactorDispatcher
public ReactorDispatcher getReactorDispatcher()
-
unsafeSetReactorDispatcher
public void unsafeSetReactorDispatcher(ReactorDispatcher reactorDispatcher)
-
onReactorInit
public void onReactorInit(org.apache.qpid.proton.engine.Event e)
- Specified by:
onReactorInitin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onReactorInitin classorg.apache.qpid.proton.engine.BaseHandler
-
onReactorFinal
public void onReactorFinal(org.apache.qpid.proton.engine.Event e)
- Specified by:
onReactorFinalin interfaceorg.apache.qpid.proton.engine.CoreHandler- Overrides:
onReactorFinalin classorg.apache.qpid.proton.engine.BaseHandler
-
-