org.apache.synapse.transport.amqp
Class AMQPListener

java.lang.Object
  org.apache.synapse.transport.base.AbstractTransportListener
      org.apache.synapse.transport.amqp.AMQPListener

All Implemented Interfaces:

TransportListener

public class AMQPListener
extends AbstractTransportListener

Field Summary

static String

TRANSPORT_NAME

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

cfgCtx, engine, isNonBlocking, metrics, state, transportName, useAxis2ThreadPool, workerPool

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

HOST_ADDRESS, PARAM_PORT

Constructor Summary

AMQPListener()

Method Summary

EndpointReference[]	getEPRsForService(String serviceName, String ip)
void	init(ConfigurationContext cfgCtx, TransportInDescription transportIn) Initialize the generic transport.
void	start()
protected void	startListeningForService(AxisService service)
void	stop()
protected void	stopListeningForService(AxisService service)

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

createMessageContext, destroy, disableTransportForService, getActiveThreadCount, getBytesReceived, getBytesSent, getEPRForService, getFaultsReceiving, getFaultsSending, getMessagesReceived, getMessagesSent, getMetricsCollector, getQueueSize, getSessionContext, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resume, setTransportName

Methods inherited from class java.lang.Object

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

Field Detail

TRANSPORT_NAME

public static final String TRANSPORT_NAME

See Also:

Constant Field Values

Constructor Detail

AMQPListener

public AMQPListener()

Method Detail

init

public void init(ConfigurationContext cfgCtx,
                 TransportInDescription transportIn)
          throws AxisFault

Description copied from class: AbstractTransportListener

Initialize the generic transport. Sets up the transport and the thread pool to be used for message processing. Also creates an AxisObserver that gets notified of service life cycle events for the transport to act on

Specified by:

init in interface TransportListener

Overrides:

init in class AbstractTransportListener

Parameters:

cfgCtx - the axis configuration context

transportIn - the transport-in description

Throws:

AxisFault - on error

start

public void start()
           throws AxisFault

Specified by:

start in interface TransportListener

Overrides:

start in class AbstractTransportListener

Throws:

AxisFault

stop

public void stop()
          throws AxisFault

Specified by:

stop in interface TransportListener

Overrides:

stop in class AbstractTransportListener

Throws:

AxisFault

startListeningForService

protected void startListeningForService(AxisService service)

Specified by:

startListeningForService in class AbstractTransportListener

stopListeningForService

protected void stopListeningForService(AxisService service)

Specified by:

stopListeningForService in class AbstractTransportListener

getEPRsForService

public EndpointReference[] getEPRsForService(String serviceName,
                                             String ip)
                                      throws AxisFault

Throws:

AxisFault