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
All Methods Static Methods Instance Methods Concrete Methods 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
-
-
-
-
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 interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onConnectionInit
in classorg.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 interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onConnectionBound
in classorg.apache.qpid.proton.engine.BaseHandler
-
onTransportError
public void onTransportError(org.apache.qpid.proton.engine.Event event)
- Specified by:
onTransportError
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onTransportError
in classorg.apache.qpid.proton.engine.BaseHandler
-
onConnectionRemoteOpen
public void onConnectionRemoteOpen(org.apache.qpid.proton.engine.Event event)
- Specified by:
onConnectionRemoteOpen
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onConnectionRemoteOpen
in classorg.apache.qpid.proton.engine.BaseHandler
-
onConnectionRemoteClose
public void onConnectionRemoteClose(org.apache.qpid.proton.engine.Event event)
- Specified by:
onConnectionRemoteClose
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onConnectionRemoteClose
in classorg.apache.qpid.proton.engine.BaseHandler
-
onConnectionFinal
public void onConnectionFinal(org.apache.qpid.proton.engine.Event event)
- Specified by:
onConnectionFinal
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onConnectionFinal
in classorg.apache.qpid.proton.engine.BaseHandler
-
onConnectionLocalClose
public void onConnectionLocalClose(org.apache.qpid.proton.engine.Event event)
- Specified by:
onConnectionLocalClose
in interfaceorg.apache.qpid.proton.engine.CoreHandler
- Overrides:
onConnectionLocalClose
in classorg.apache.qpid.proton.engine.BaseHandler
-
-