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

Class AmqpConnectionHandler

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandler

com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandlerWithCleanup

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

All Implemented Interfaces:

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

Direct Known Subclasses:

AmqpFeedbackReceivedHandler, AmqpFileUploadNotificationReceivedHandler, AmqpSendHandler

public class AmqpConnectionHandler
extends com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandlerWithCleanup

Field Summary

Fields

Modifier and Type	Field and Description
static String	AMQPS_PORT
static String	AMQPS_WS_PORT
protected boolean	connectionOpenedRemotely
protected String	hostName
protected IotHubServiceClientProtocol	iotHubServiceClientProtocol
protected boolean	linkOpenedRemotely
protected String	sasToken
protected Exception	savedException
protected boolean	sessionOpenedRemotely
protected String	userName
static String	WEBSOCKET_PATH
static String	WEBSOCKET_SUB_PROTOCOL
protected String	webSocketHostName

Fields inherited from class com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandler

protonJExceptionParser

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AmqpConnectionHandler(String hostName, String userName, String sasToken, IotHubServiceClientProtocol iotHubServiceClientProtocol)

Method Summary

Modifier and Type	Method and Description
void	onConnectionBound(org.apache.qpid.proton.engine.Event event) Event handler for the connection bound event
void	onConnectionRemoteOpen(org.apache.qpid.proton.engine.Event event)
void	onLinkRemoteOpen(org.apache.qpid.proton.engine.Event event)
void	onReactorInit(org.apache.qpid.proton.engine.Event event)
void	onSessionRemoteOpen(org.apache.qpid.proton.engine.Event event)
protected void	verifyConnectionWasOpened() If an exception was encountered while opening the AMQP connection, this function shall throw that saved exception

Methods inherited from class com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandlerWithCleanup

onConnectionLocalClose, onConnectionLocalOpen, onConnectionRemoteClose, onLinkLocalClose, onLinkLocalOpen, onLinkRemoteClose, onSessionLocalClose, onSessionLocalOpen, onSessionRemoteClose, onTransportError

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

add, children, getHandler, getHandler, handle, onConnectionFinal, onConnectionInit, onConnectionUnbound, onDelivery, onLinkFinal, onLinkFlow, onLinkInit, onLinkLocalDetach, onLinkRemoteDetach, onReactorFinal, 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

Field Detail

WEBSOCKET_PATH

public static final String WEBSOCKET_PATH

See Also:

Constant Field Values

WEBSOCKET_SUB_PROTOCOL

public static final String WEBSOCKET_SUB_PROTOCOL

See Also:

Constant Field Values

AMQPS_PORT

public static final String AMQPS_PORT

See Also:

Constant Field Values

AMQPS_WS_PORT

public static final String AMQPS_WS_PORT

See Also:

Constant Field Values

savedException

protected Exception savedException

connectionOpenedRemotely

protected boolean connectionOpenedRemotely

sessionOpenedRemotely

protected boolean sessionOpenedRemotely

linkOpenedRemotely

protected boolean linkOpenedRemotely

hostName

protected final String hostName

userName

protected final String userName

sasToken

protected final String sasToken

iotHubServiceClientProtocol

protected final IotHubServiceClientProtocol iotHubServiceClientProtocol

webSocketHostName

protected final String webSocketHostName

Constructor Detail

AmqpConnectionHandler

protected AmqpConnectionHandler(String hostName,
                                String userName,
                                String sasToken,
                                IotHubServiceClientProtocol iotHubServiceClientProtocol)

Method Detail

onReactorInit

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

Specified by:

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

Overrides:

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

onConnectionBound

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

Event handler for the connection bound event

Specified by:

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

Overrides:

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

Parameters:

event - The proton event object

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 com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandlerWithCleanup

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 com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandlerWithCleanup

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 com.microsoft.azure.sdk.iot.deps.transport.amqp.ErrorLoggingBaseHandlerWithCleanup

verifyConnectionWasOpened

protected void verifyConnectionWasOpened()
                                  throws IOException

If an exception was encountered while opening the AMQP connection, this function shall throw that saved exception

Throws:

IOException - if an exception was encountered while openinging the AMQP connection. The encountered exception will be the inner exception