Package org.wso2.carbon.cloud.gateway.agent.transport

Class CGPollingTransportBuffers

java.lang.Object

org.wso2.carbon.cloud.gateway.agent.transport.CGPollingTransportBuffers

public class CGPollingTransportBuffers
extends Object

Represent the transport level exchange buffers for workers ( csg polling transport)

Constructor Summary

Constructors

Constructor	Description
CGPollingTransportBuffers()

Method Summary

Modifier and Type	Method	Description
void	addResponseMessage(org.wso2.carbon.cloud.gateway.common.thrift.gen.Message msg)	Add a response message to the response buffer
org.wso2.carbon.cloud.gateway.common.thrift.gen.Message	getRequestMessage()	Returns a request message from the request message buffer
BlockingQueue<org.wso2.carbon.cloud.gateway.common.thrift.gen.Message>	getRequestMessageBuffer()	Returns the request message buffer in transport
List<org.wso2.carbon.cloud.gateway.common.thrift.gen.Message>	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

CGPollingTransportBuffers

public CGPollingTransportBuffers()

Method Detail

getResponseMessageList

public List<org.wso2.carbon.cloud.gateway.common.thrift.gen.Message> getResponseMessageList(int blockSize)
                                                                                     throws org.apache.axis2.AxisFault

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:

org.apache.axis2.AxisFault - in case of an error

addResponseMessage

public void addResponseMessage(org.wso2.carbon.cloud.gateway.common.thrift.gen.Message msg)
                        throws org.apache.axis2.AxisFault

Add a response message to the response buffer

Parameters:

msg - the response message

Throws:

org.apache.axis2.AxisFault - throws in case of an error

getRequestMessageBuffer

public BlockingQueue<org.wso2.carbon.cloud.gateway.common.thrift.gen.Message> getRequestMessageBuffer()

Returns the request message buffer in transport

Returns:

the request message buffer

getRequestMessage

public org.wso2.carbon.cloud.gateway.common.thrift.gen.Message getRequestMessage()

Returns a request message from the request message buffer

Returns:

the thrift message