Package com.microsoft.azure.servicebus.amqp

Class ConnectionHandler

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

com.microsoft.azure.servicebus.amqp.ConnectionHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

WebSocketConnectionHandler

public class ConnectionHandler
extends org.apache.qpid.proton.engine.BaseHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected IAmqpConnection	messagingFactory

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectionHandler(IAmqpConnection messagingFactory)

Method Summary

Modifier and Type	Method	Description
void	addTransportLayers(org.apache.qpid.proton.engine.Event event, org.apache.qpid.proton.engine.impl.TransportInternal transport)
static ConnectionHandler	create(TransportType transportType, IAmqpConnection messagingFactory)
int	getMaxFrameSize()
protected IAmqpConnection	getMessagingFactory()
String	getOutboundSocketHostName()
int	getOutboundSocketPort()
int	getProtocolPort()
protected void	notifyTransportErrors(org.apache.qpid.proton.engine.Event event)
void	onConnectionBound(org.apache.qpid.proton.engine.Event event)
void	onConnectionFinal(org.apache.qpid.proton.engine.Event event)
void	onConnectionInit(org.apache.qpid.proton.engine.Event event)
void	onConnectionLocalClose(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	onTransportError(org.apache.qpid.proton.engine.Event event)

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

add, children, getHandler, getHandler, handle, onConnectionLocalOpen, onConnectionUnbound, onDelivery, onLinkFinal, onLinkFlow, onLinkInit, onLinkLocalClose, onLinkLocalDetach, onLinkLocalOpen, onLinkRemoteClose, onLinkRemoteDetach, onLinkRemoteOpen, onReactorFinal, onReactorInit, onReactorQuiesced, onSelectableError, onSelectableExpired, onSelectableFinal, onSelectableInit, onSelectableReadable, onSelectableUpdated, onSelectableWritable, onSessionFinal, onSessionInit, onSessionLocalClose, onSessionLocalOpen, onSessionRemoteClose, onSessionRemoteOpen, 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

messagingFactory

protected final IAmqpConnection messagingFactory

Constructor Detail

ConnectionHandler

protected ConnectionHandler(IAmqpConnection messagingFactory)

Method Detail

create

public static ConnectionHandler create(TransportType transportType,
                                       IAmqpConnection messagingFactory)

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

getMessagingFactory

protected IAmqpConnection getMessagingFactory()

addTransportLayers

public void addTransportLayers(org.apache.qpid.proton.engine.Event event,
                               org.apache.qpid.proton.engine.impl.TransportInternal transport)

notifyTransportErrors

protected void notifyTransportErrors(org.apache.qpid.proton.engine.Event event)

getOutboundSocketHostName

public String getOutboundSocketHostName()

getOutboundSocketPort

public int getOutboundSocketPort()

getProtocolPort

public int getProtocolPort()

getMaxFrameSize

public int getMaxFrameSize()

onConnectionBound

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

Specified by:

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

Overrides:

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

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 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

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 org.apache.qpid.proton.engine.BaseHandler

onConnectionFinal

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

Specified by:

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

Overrides:

onConnectionFinal 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