com.microsoft.azure.sdk.iot.service.transport.amqps

Class ErrorLoggingBaseHandlerWithCleanup

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

com.microsoft.azure.sdk.iot.service.transport.amqps.ErrorLoggingBaseHandler

com.microsoft.azure.sdk.iot.service.transport.amqps.ErrorLoggingBaseHandlerWithCleanup

All Implemented Interfaces:

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

Direct Known Subclasses:

CloudToDeviceMessageConnectionHandler, EventReceivingConnectionHandler

public class ErrorLoggingBaseHandlerWithCleanup
extends ErrorLoggingBaseHandler

Base Handler that logs connection/session/link opening. It also has logic to tear down the connection/session/link and stop the reactor if the connection, session, and/or link is closed remotely. This base handler assumes a single link in a single session in a single connection.

Field Summary

Fields inherited from class com.microsoft.azure.sdk.iot.service.transport.amqps.ErrorLoggingBaseHandler

errorProcessor, protonJExceptionParser

Constructor Summary

Constructors

Constructor and Description
ErrorLoggingBaseHandlerWithCleanup()

Method Summary

Modifier and Type	Method and Description
void	onConnectionLocalClose(org.apache.qpid.proton.engine.Event event)
void	onConnectionLocalOpen(org.apache.qpid.proton.engine.Event event)
void	onConnectionRemoteClose(org.apache.qpid.proton.engine.Event event)
void	onConnectionRemoteOpen(org.apache.qpid.proton.engine.Event event)
void	onLinkLocalClose(org.apache.qpid.proton.engine.Event event)
void	onLinkLocalOpen(org.apache.qpid.proton.engine.Event event)
void	onLinkRemoteClose(org.apache.qpid.proton.engine.Event event)
void	onLinkRemoteOpen(org.apache.qpid.proton.engine.Event event)
void	onSessionLocalClose(org.apache.qpid.proton.engine.Event event)
void	onSessionLocalOpen(org.apache.qpid.proton.engine.Event event)
void	onSessionRemoteClose(org.apache.qpid.proton.engine.Event event)
void	onSessionRemoteOpen(org.apache.qpid.proton.engine.Event event)
void	onTransportError(org.apache.qpid.proton.engine.Event event)

Methods inherited from class org.apache.qpid.proton.engine.BaseHandler

add, children, getHandler, getHandler, handle, onConnectionBound, onConnectionFinal, onConnectionInit, onConnectionUnbound, onDelivery, onLinkFinal, onLinkFlow, onLinkInit, onLinkLocalDetach, onLinkRemoteDetach, onReactorFinal, onReactorInit, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionFinal, onSessionInit, onTimerTask, onTransport, onTransportClosed, onTransportHeadClosed, onTransportTailClosed, onUnhandled, setHandler, setHandler

Methods inherited from class java.lang.Object

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

Constructor Detail

ErrorLoggingBaseHandlerWithCleanup

public ErrorLoggingBaseHandlerWithCleanup()

Method Detail

onLinkRemoteClose

public void onLinkRemoteClose(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

onLinkRemoteClose in class ErrorLoggingBaseHandler

onSessionRemoteClose

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

Specified by:

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

Overrides:

onSessionRemoteClose in class ErrorLoggingBaseHandler

onConnectionRemoteClose

public void onConnectionRemoteClose(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

onConnectionRemoteClose in class ErrorLoggingBaseHandler

onTransportError

public void onTransportError(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

onTransportError in class ErrorLoggingBaseHandler

onLinkRemoteOpen

public void onLinkRemoteOpen(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

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

onConnectionRemoteOpen

public void onConnectionRemoteOpen(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

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

onSessionRemoteOpen

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

Specified by:

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

Overrides:

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

onLinkLocalOpen

public void onLinkLocalOpen(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

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

onConnectionLocalOpen

public void onConnectionLocalOpen(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

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

onSessionLocalOpen

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

Specified by:

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

Overrides:

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

onLinkLocalClose

public void onLinkLocalClose(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

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

onSessionLocalClose

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

Specified by:

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

Overrides:

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

onConnectionLocalClose

public void onConnectionLocalClose(org.apache.qpid.proton.engine.Event event)

Specified by:

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

Overrides:

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