Uses of Class
org.apache.synapse.transport.amqp.AMQPTransportMessage

Packages that use AMQPTransportMessage

Package	Description
org.apache.synapse.transport.amqp
org.apache.synapse.transport.amqp.pollingtask

Uses of AMQPTransportMessage in org.apache.synapse.transport.amqp

Methods in org.apache.synapse.transport.amqp that return AMQPTransportMessage

Modifier and Type	Method and Description
AMQPTransportMessage	AMQPTransportBuffers.getRequestMessage() Returns a request message from the request message buffer

Methods in org.apache.synapse.transport.amqp that return types with arguments of type AMQPTransportMessage

Modifier and Type	Method and Description
BlockingQueue<AMQPTransportMessage>	AMQPTransportBuffers.getRequestMessageBuffer() Returns the request message buffer in transport
List<AMQPTransportMessage>	AMQPTransportBuffers.getResponseMessageList(int blockSize) Returns the response messages as a list

Methods in org.apache.synapse.transport.amqp with parameters of type AMQPTransportMessage

Modifier and Type	Method and Description
void	AMQPTransportBuffers.addRequestMessage(AMQPTransportMessage msg) Add a message to the request message buffer
void	AMQPTransportBuffers.addResponseMessage(AMQPTransportMessage msg) Add a response message to the response buffer

Method parameters in org.apache.synapse.transport.amqp with type arguments of type AMQPTransportMessage

Modifier and Type	Method and Description
static void	AMQPTransportUtils.moveElements(BlockingQueue<AMQPTransportMessage> src, List<AMQPTransportMessage> dest, int blockSize) Move elements between buffers.
static void	AMQPTransportUtils.moveElements(BlockingQueue<AMQPTransportMessage> src, List<AMQPTransportMessage> dest, int blockSize) Move elements between buffers.

Uses of AMQPTransportMessage in org.apache.synapse.transport.amqp.pollingtask

Constructor parameters in org.apache.synapse.transport.amqp.pollingtask with type arguments of type AMQPTransportMessage

Constructor and Description
AMQPSimpleConsumerTask(ExecutorService workerPool, com.rabbitmq.client.Channel channel, String queueName, Map<String,Semaphore> responseTracker, Map<String,AMQPTransportMessage> responseMessage)