org.apache.synapse.transport.amqp.pollingtask

Class AMQPTransportPollingTask

java.lang.Object

org.apache.synapse.transport.amqp.pollingtask.AMQPTransportPollingTask

public class AMQPTransportPollingTask
extends Object

The polling task deploy for each services exposed on AMQP transport. This task

Constructor Summary

Constructors

Constructor and Description
AMQPTransportPollingTask()

Method Summary

Modifier and Type	Method and Description
String[]	getBindingsKeys()
String	getConsumerExchangeName()
AMQPTransportEndpoint	getEndpoint()
String	getExchangeName()
String	getExchangeType()
int	getNoOfConcurrentConsumers()
int	getNoOfDispatchingTask()
ExecutorService	getPollingTaskScheduler()
String	getQueueName()
TimeUnit	getScheduledTaskTimeUnit()
String	getServiceName()
boolean	isBlockingMode()
boolean	isExchangeAutoDelete()
boolean	isExchangeDurable()
boolean	isInternalExchange()
boolean	isQueueAutoDelete()
boolean	isQueueDurable()
boolean	isQueueRestricted()
void	setBindingsKeys(String[] bindingsKeys)
void	setBlockingMode(boolean blockingMode)
void	setBuffers(AMQPTransportBuffers buffers)
void	setChannel(com.rabbitmq.client.Channel channel)
void	setConfiguredContentType(String configuredContentType)
void	setConnectionFactoryName(String connectionFactoryName)
void	setConsumerExchangeName(String consumerExchangeName)
void	setEndpoint(AMQPTransportEndpoint endpoint)
void	setExchangeAutoDelete(boolean exchangeAutoDelete)
void	setExchangeDurable(boolean isExchangeDurable)
void	setExchangeName(String exchangeName)
void	setExchangeType(String exchangeType)
void	setHaHandler(AMQPTransportReconnectHandler haHandler)
void	setInternalExchange(boolean internalExchange)
void	setNoOfConcurrentConsumers(int noOfConcurrentConsumers)
void	setNoOfDispatchingTask(int noOfDispatchingTask)
void	setPollingTaskScheduler(ScheduledExecutorService pollingTaskScheduler)
void	setQueueAutoDelete(boolean queueAutoDelete)
void	setQueueDurable(boolean queueDurable)
void	setQueueName(String queueName)
void	setQueueRestricted(boolean queueRestricted)
void	setResponseConnectionFactory(String responseConnectionFactory)
void	setScheduledTaskDelay(int scheduledTaskDelay)
void	setScheduledTaskInitialDelay(int scheduledTaskInitialDelay)
void	setScheduledTaskTimeUnit(TimeUnit scheduledTaskTimeUnit)
void	setServiceName(String serviceName)
void	setUseTx(boolean useTx)
void	start() Start the polling task for this service
void	stop() Stop the polling tasks

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportPollingTask

public AMQPTransportPollingTask()

Method Detail

setUseTx

public void setUseTx(boolean useTx)

setChannel

public void setChannel(com.rabbitmq.client.Channel channel)

setConfiguredContentType

public void setConfiguredContentType(String configuredContentType)

setBuffers

public void setBuffers(AMQPTransportBuffers buffers)

setEndpoint

public void setEndpoint(AMQPTransportEndpoint endpoint)

setServiceName

public void setServiceName(String serviceName)

setExchangeName

public void setExchangeName(String exchangeName)

setExchangeDurable

public void setExchangeDurable(boolean isExchangeDurable)

setExchangeAutoDelete

public void setExchangeAutoDelete(boolean exchangeAutoDelete)

setExchangeType

public void setExchangeType(String exchangeType)

setInternalExchange

public void setInternalExchange(boolean internalExchange)

setConsumerExchangeName

public void setConsumerExchangeName(String consumerExchangeName)

setBindingsKeys

public void setBindingsKeys(String[] bindingsKeys)

setQueueName

public void setQueueName(String queueName)

setQueueDurable

public void setQueueDurable(boolean queueDurable)

setQueueRestricted

public void setQueueRestricted(boolean queueRestricted)

setQueueAutoDelete

public void setQueueAutoDelete(boolean queueAutoDelete)

setBlockingMode

public void setBlockingMode(boolean blockingMode)

setNoOfConcurrentConsumers

public void setNoOfConcurrentConsumers(int noOfConcurrentConsumers)

setConnectionFactoryName

public void setConnectionFactoryName(String connectionFactoryName)

setScheduledTaskInitialDelay

public void setScheduledTaskInitialDelay(int scheduledTaskInitialDelay)

setScheduledTaskDelay

public void setScheduledTaskDelay(int scheduledTaskDelay)

setScheduledTaskTimeUnit

public void setScheduledTaskTimeUnit(TimeUnit scheduledTaskTimeUnit)

setNoOfDispatchingTask

public void setNoOfDispatchingTask(int noOfDispatchingTask)

setPollingTaskScheduler

public void setPollingTaskScheduler(ScheduledExecutorService pollingTaskScheduler)

getServiceName

public String getServiceName()

getExchangeName

public String getExchangeName()

isExchangeDurable

public boolean isExchangeDurable()

isExchangeAutoDelete

public boolean isExchangeAutoDelete()

getExchangeType

public String getExchangeType()

isInternalExchange

public boolean isInternalExchange()

getConsumerExchangeName

public String getConsumerExchangeName()

getBindingsKeys

public String[] getBindingsKeys()

getQueueName

public String getQueueName()

isQueueDurable

public boolean isQueueDurable()

isQueueRestricted

public boolean isQueueRestricted()

isQueueAutoDelete

public boolean isQueueAutoDelete()

isBlockingMode

public boolean isBlockingMode()

getNoOfConcurrentConsumers

public int getNoOfConcurrentConsumers()

getScheduledTaskTimeUnit

public TimeUnit getScheduledTaskTimeUnit()

getNoOfDispatchingTask

public int getNoOfDispatchingTask()

getPollingTaskScheduler

public ExecutorService getPollingTaskScheduler()

getEndpoint

public AMQPTransportEndpoint getEndpoint()

setResponseConnectionFactory

public void setResponseConnectionFactory(String responseConnectionFactory)

setHaHandler

public void setHaHandler(AMQPTransportReconnectHandler haHandler)

start

public void start()
           throws AMQPTransportException

Start the polling task for this service

Throws:

AMQPTransportException

stop

public void stop()

Stop the polling tasks