org.apache.synapse.transport.amqp.pollingtask

Class AMQPTransportPollingTaskFactory

java.lang.Object

org.apache.synapse.transport.amqp.pollingtask.AMQPTransportPollingTaskFactory

public class AMQPTransportPollingTaskFactory
extends Object

The factory implementation for AMQPTransportPollingTask. Polling task(with multiple) consumers will be deployed for each deployed service.

Constructor Summary

Constructors

Constructor and Description
AMQPTransportPollingTaskFactory()

Method Summary

Modifier and Type	Method and Description
static AMQPTransportPollingTask	createPollingTaskForService(org.apache.axis2.description.AxisService service, ScheduledExecutorService pool, AMQPTransportEndpoint endpoint, AMQPTransportConnectionFactory connectionFactory, AMQPTransportReconnectHandler haHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportPollingTaskFactory

public AMQPTransportPollingTaskFactory()

Method Detail

createPollingTaskForService

public static AMQPTransportPollingTask createPollingTaskForService(org.apache.axis2.description.AxisService service,
                                                                   ScheduledExecutorService pool,
                                                                   AMQPTransportEndpoint endpoint,
                                                                   AMQPTransportConnectionFactory connectionFactory,
                                                                   AMQPTransportReconnectHandler haHandler)
                                                            throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault