Package com.microsoft.azure.eventhubs.impl

Class SessionHandler

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

com.microsoft.azure.eventhubs.impl.SessionHandler

All Implemented Interfaces:

org.apache.qpid.proton.engine.CoreHandler, org.apache.qpid.proton.engine.Handler

public class SessionHandler
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
SessionHandler(String entityName, Consumer<org.apache.qpid.proton.engine.Session> onRemoteSessionOpen, BiConsumer<org.apache.qpid.proton.amqp.transport.ErrorCondition,Exception> onRemoteSessionOpenError, Duration openTimeout, String connectionId)

Method Summary

Modifier and Type	Method	Description
void	onSessionFinal(org.apache.qpid.proton.engine.Event e)
void	onSessionLocalClose(org.apache.qpid.proton.engine.Event e)
void	onSessionLocalOpen(org.apache.qpid.proton.engine.Event e)
void	onSessionRemoteClose(org.apache.qpid.proton.engine.Event e)
void	onSessionRemoteOpen(org.apache.qpid.proton.engine.Event e)

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, onReactorFinal, onReactorInit, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionInit, onTimerTask, onTransport, onTransportClosed, onTransportError, onTransportHeadClosed, onTransportTailClosed, onUnhandled, setHandler, setHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TRACE_LOGGER

protected static final org.slf4j.Logger TRACE_LOGGER

Constructor Detail

SessionHandler

public SessionHandler(String entityName,
                      Consumer<org.apache.qpid.proton.engine.Session> onRemoteSessionOpen,
                      BiConsumer<org.apache.qpid.proton.amqp.transport.ErrorCondition,Exception> onRemoteSessionOpenError,
                      Duration openTimeout,
                      String connectionId)

Method Detail

onSessionLocalOpen

public void onSessionLocalOpen(org.apache.qpid.proton.engine.Event e)

Specified by:

onSessionLocalOpen in interface org.apache.qpid.proton.engine.CoreHandler

Overrides:

onSessionLocalOpen in class org.apache.qpid.proton.engine.BaseHandler

onSessionRemoteOpen

public void onSessionRemoteOpen(org.apache.qpid.proton.engine.Event e)

Specified by:

onSessionRemoteOpen in interface org.apache.qpid.proton.engine.CoreHandler

Overrides:

onSessionRemoteOpen in class org.apache.qpid.proton.engine.BaseHandler

onSessionLocalClose

public void onSessionLocalClose(org.apache.qpid.proton.engine.Event e)

Specified by:

onSessionLocalClose in interface org.apache.qpid.proton.engine.CoreHandler

Overrides:

onSessionLocalClose in class org.apache.qpid.proton.engine.BaseHandler

onSessionRemoteClose

public void onSessionRemoteClose(org.apache.qpid.proton.engine.Event e)

Specified by:

onSessionRemoteClose in interface org.apache.qpid.proton.engine.CoreHandler

Overrides:

onSessionRemoteClose in class org.apache.qpid.proton.engine.BaseHandler

onSessionFinal

public void onSessionFinal(org.apache.qpid.proton.engine.Event e)

Specified by:

onSessionFinal in interface org.apache.qpid.proton.engine.CoreHandler

Overrides:

onSessionFinal in class org.apache.qpid.proton.engine.BaseHandler