org.apache.synapse.transport.amqp

Class AMQPTransportEndpoint

java.lang.Object

org.apache.axis2.transport.base.ProtocolEndpoint

org.apache.synapse.transport.amqp.AMQPTransportEndpoint

public class AMQPTransportEndpoint
extends org.apache.axis2.transport.base.ProtocolEndpoint

Represent and endpoint in AMQP transport implementation.

Constructor Summary

Constructors

Constructor and Description
AMQPTransportEndpoint(ScheduledExecutorService workerPool, AMQPTransportListener receiver)

Method Summary

Modifier and Type	Method and Description
org.apache.axis2.addressing.EndpointReference[]	getEndpointReferences(org.apache.axis2.description.AxisService service, String ip)
AMQPTransportPollingTask	getPollingTask()
boolean	loadConfiguration(org.apache.axis2.description.ParameterInclude params)

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

createMessageContext, getConfigurationContext, getDescription, getListener, getService, getServiceName

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportEndpoint

public AMQPTransportEndpoint(ScheduledExecutorService workerPool,
                             AMQPTransportListener receiver)

Method Detail

getPollingTask

public AMQPTransportPollingTask getPollingTask()

loadConfiguration

public boolean loadConfiguration(org.apache.axis2.description.ParameterInclude params)
                          throws org.apache.axis2.AxisFault

Specified by:

loadConfiguration in class org.apache.axis2.transport.base.ProtocolEndpoint

Throws:

org.apache.axis2.AxisFault

getEndpointReferences

public org.apache.axis2.addressing.EndpointReference[] getEndpointReferences(org.apache.axis2.description.AxisService service,
                                                                             String ip)
                                                                      throws org.apache.axis2.AxisFault

Specified by:

getEndpointReferences in class org.apache.axis2.transport.base.ProtocolEndpoint

Throws:

org.apache.axis2.AxisFault