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

Class AmqpFileUploadNotificationReceivedHandler

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

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

All Implemented Interfaces:

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

public class AmqpFileUploadNotificationReceivedHandler
extends AmqpConnectionHandler

Instance of the QPID-Proton-J BaseHandler class to override the events what are needed to handle the receive operation Contains and sets connection parameters (path, port, endpoint) Maintains the layers of AMQP protocol (Link, Session, Connection, Transport) Creates and sets SASL authentication for transport

Field Summary

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

AMQPS_PORT, AMQPS_WS_PORT, connectionOpenedRemotely, hostName, iotHubServiceClientProtocol, linkOpenedRemotely, sasToken, savedException, sessionOpenedRemotely, userName, WEBSOCKET_PATH, WEBSOCKET_SUB_PROTOCOL, webSocketHostName

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

protonJExceptionParser

Method Summary

Modifier and Type	Method and Description
void	onConnectionInit(org.apache.qpid.proton.engine.Event event)
void	onDelivery(org.apache.qpid.proton.engine.Event event) Event handler for the on delivery event
void	onLinkInit(org.apache.qpid.proton.engine.Event event)
void	onTimerTask(org.apache.qpid.proton.engine.Event event)

Methods inherited from class com.microsoft.azure.sdk.iot.service.transport.amqps.AmqpConnectionHandler

onConnectionBound, onConnectionRemoteOpen, onLinkRemoteOpen, onReactorInit, onSessionRemoteOpen, verifyConnectionWasOpened

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, onConnectionUnbound, onLinkFinal, onLinkFlow, onLinkLocalDetach, onLinkRemoteDetach, onReactorFinal, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionFinal, onSessionInit, 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

Method Detail

onTimerTask

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

Specified by:

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

Overrides:

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

onDelivery

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

Event handler for the on delivery event

Specified by:

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

Overrides:

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

Parameters:

event - The proton event object

onConnectionInit

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

Specified by:

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

Overrides:

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

onLinkInit

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

Specified by:

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

Overrides:

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