org.apache.synapse.transport.amqp

Class AMQPTransportListener

java.lang.Object

org.apache.axis2.transport.base.AbstractTransportListener

org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

org.apache.synapse.transport.amqp.AMQPTransportListener

All Implemented Interfaces:

org.apache.axis2.transport.TransportListener

public class AMQPTransportListener
extends org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

The AMQP transport receiver implementation.

Field Summary

Fields inherited from class org.apache.axis2.transport.base.AbstractTransportListener

cfgCtx, config, isNonBlocking, log, metrics, state, useAxis2ThreadPool

Fields inherited from interface org.apache.axis2.transport.TransportListener

HOST_ADDRESS, PARAM_PORT

Constructor Summary

Constructors

Constructor and Description
AMQPTransportListener()

Method Summary

Modifier and Type	Method and Description
protected AMQPTransportEndpoint	createEndpoint()
protected void	doInit()
AMQPTransportConnectionFactory	getConnectionFactory(String name) Returns the connection factory with this name.
AMQPTransportReconnectHandler	getHaHandler()
protected void	startEndpoint(AMQPTransportEndpoint endpoint)
void	stop()
protected void	stopEndpoint(AMQPTransportEndpoint endpoint)

Methods inherited from class org.apache.axis2.transport.base.AbstractTransportListenerEx

getEndpoints, getEPRsForService, init, start, startListeningForService, stopListeningForService

Methods inherited from class org.apache.axis2.transport.base.AbstractTransportListener

createMessageContext, destroy, disableTransportForService, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getConfigurationContext, getEPRForService, getEPRsForService, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsCollector, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getSessionContext, getTimeoutsReceiving, getTimeoutsSending, getTransportInDescription, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resetStatistics, resume

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AMQPTransportListener

public AMQPTransportListener()

Method Detail

doInit

protected void doInit()
               throws org.apache.axis2.AxisFault

Specified by:

doInit in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

Throws:

org.apache.axis2.AxisFault

createEndpoint

protected AMQPTransportEndpoint createEndpoint()

Specified by:

createEndpoint in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

startEndpoint

protected void startEndpoint(AMQPTransportEndpoint endpoint)
                      throws org.apache.axis2.AxisFault

Specified by:

startEndpoint in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

Throws:

org.apache.axis2.AxisFault

stopEndpoint

protected void stopEndpoint(AMQPTransportEndpoint endpoint)

Specified by:

stopEndpoint in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

stop

public void stop()
          throws org.apache.axis2.AxisFault

Specified by:

stop in interface org.apache.axis2.transport.TransportListener

Overrides:

stop in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>

Throws:

org.apache.axis2.AxisFault

getConnectionFactory

public AMQPTransportConnectionFactory getConnectionFactory(String name)
                                                    throws AMQPTransportException

Returns the connection factory with this name.

Parameters:

name - Name of the connection factory.

Returns:

The connection factory with this name.

Throws:

AMQPTransportException - throws in case of an error.

getHaHandler

public AMQPTransportReconnectHandler getHaHandler()