org.apache.synapse.transport.amqp

Class AMQPTransportBuffers

java.lang.Object

org.apache.synapse.transport.amqp.AMQPTransportBuffers

public class AMQPTransportBuffers
extends Object

Keeps the request/response messages until pick by the processing/response dispatching tasks. These buffers(an instance of http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/BlockingQueue.html) are used in order to define an asynchronous architecture between the polling tak and actual processing which will lead to higher performance.

Constructor Summary

Constructors

Constructor and Description
AMQPTransportBuffers()

Method Summary

Modifier and Type	Method and Description
void	addRequestMessage(AMQPTransportMessage msg) Add a message to the request message buffer
void	addResponseMessage(AMQPTransportMessage msg) Add a response message to the response buffer
AMQPTransportMessage	getRequestMessage() Returns a request message from the request message buffer
BlockingQueue<AMQPTransportMessage>	getRequestMessageBuffer() Returns the request message buffer in transport
List<AMQPTransportMessage>	getResponseMessageList(int blockSize) Returns the response messages as a list

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportBuffers

public AMQPTransportBuffers()

Method Detail

getResponseMessageList

public List<AMQPTransportMessage> getResponseMessageList(int blockSize)
                                                  throws AMQPTransportException

Returns the response messages as a list

Parameters:

blockSize - the block blockSize of the response message list

Returns:

the block of the response messages of blockSize

Throws:

AMQPTransportException - in case of an error

addResponseMessage

public void addResponseMessage(AMQPTransportMessage msg)
                        throws InterruptedException

Add a response message to the response buffer

Parameters:

msg - the response message

Throws:

InterruptedException - throws in case of an error

getRequestMessageBuffer

public BlockingQueue<AMQPTransportMessage> getRequestMessageBuffer()

Returns the request message buffer in transport

Returns:

the request message buffer

addRequestMessage

public void addRequestMessage(AMQPTransportMessage msg)

Add a message to the request message buffer

Parameters:

msg - the message to add into the buffer

getRequestMessage

public AMQPTransportMessage getRequestMessage()

Returns a request message from the request message buffer

Returns:

the request message