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 ReactorDispatcher
getReactorDispatcher()
void
onReactorFinal(org.apache.qpid.proton.engine.Event e)
void
onReactorInit(org.apache.qpid.proton.engine.Event e)
void
unsafeSetReactorDispatcher(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:
onReactorInit
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onReactorInit
in classorg.apache.qpid.proton.engine.BaseHandler
-
onReactorFinal
public void onReactorFinal(org.apache.qpid.proton.engine.Event e)
- Specified by:
onReactorFinal
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onReactorFinal
in classorg.apache.qpid.proton.engine.BaseHandler
-
-