public class CGPollingTransportBuffers extends Object
Constructor and Description |
---|
CGPollingTransportBuffers() |
Modifier and Type | Method and 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
|
public List<org.wso2.carbon.cloud.gateway.common.thrift.gen.Message> getResponseMessageList(int blockSize) throws org.apache.axis2.AxisFault
blockSize
- the block blockSize of the response message listorg.apache.axis2.AxisFault
- in case of an errorpublic void addResponseMessage(org.wso2.carbon.cloud.gateway.common.thrift.gen.Message msg) throws org.apache.axis2.AxisFault
msg
- the response messageorg.apache.axis2.AxisFault
- throws in case of an errorpublic BlockingQueue<org.wso2.carbon.cloud.gateway.common.thrift.gen.Message> getRequestMessageBuffer()
public org.wso2.carbon.cloud.gateway.common.thrift.gen.Message getRequestMessage()
Copyright © 2019 WSO2. All rights reserved.