Package com.microsoft.azure.servicebus.amqp

Class ProxyConnectionHandler

java.lang.Object

org.apache.qpid.proton.engine.BaseHandler

com.microsoft.azure.servicebus.amqp.ConnectionHandler

com.microsoft.azure.servicebus.amqp.WebSocketConnectionHandler

com.microsoft.azure.servicebus.amqp.ProxyConnectionHandler

All Implemented Interfaces:

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

public class ProxyConnectionHandler
extends WebSocketConnectionHandler

Field Summary

Fields inherited from class com.microsoft.azure.servicebus.amqp.ConnectionHandler

messagingFactory

Constructor Summary

Constructors

Constructor	Description
ProxyConnectionHandler(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)
String	getOutboundSocketHostName()
int	getOutboundSocketPort()
protected void	notifyTransportErrors(org.apache.qpid.proton.engine.Event event)
static boolean	shouldUseProxy(String hostName)

Methods inherited from class com.microsoft.azure.servicebus.amqp.WebSocketConnectionHandler

getMaxFrameSize, getProtocolPort

Methods inherited from class com.microsoft.azure.servicebus.amqp.ConnectionHandler

create, getMessagingFactory, onConnectionBound, onConnectionFinal, onConnectionInit, onConnectionLocalClose, onConnectionRemoteClose, onConnectionRemoteOpen, onTransportError

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

Constructor Detail

ProxyConnectionHandler

public ProxyConnectionHandler(IAmqpConnection messagingFactory)

Method Detail

shouldUseProxy

public static boolean shouldUseProxy(String hostName)

addTransportLayers

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

Overrides:

addTransportLayers in class WebSocketConnectionHandler

notifyTransportErrors

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

Overrides:

notifyTransportErrors in class ConnectionHandler

getOutboundSocketHostName

public String getOutboundSocketHostName()

Overrides:

getOutboundSocketHostName in class ConnectionHandler

getOutboundSocketPort

public int getOutboundSocketPort()

Overrides:

getOutboundSocketPort in class ConnectionHandler