Package | Description |
---|---|
org.wso2.carbon.cloud.gateway.common | |
org.wso2.carbon.cloud.gateway.common.thrift | |
org.wso2.carbon.cloud.gateway.common.thrift.gen |
Modifier and Type | Method and Description |
---|---|
static void |
CGUtils.moveElements(BlockingQueue<Message> src,
List<Message> dest,
int blockSize)
Move elements between buffers.
|
static void |
CGUtils.moveElements(BlockingQueue<Message> src,
List<Message> dest,
int blockSize)
Move elements between buffers.
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
CGThriftClient.exchange(List<Message> src,
int size,
String token)
The exchange operation, this will pass the response buffer to the server and will
receive request buffer from the server
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
CGThriftClient.exchange(List<Message> src,
int size,
String token)
The exchange operation, this will pass the response buffer to the server and will
receive request buffer from the server
|
Modifier and Type | Field and Description |
---|---|
List<Message> |
CloudGatewayService.exchange_args.src |
List<Message> |
CloudGatewayService.exchange_result.success |
Modifier and Type | Method and Description |
---|---|
Message |
Message.deepCopy() |
Message |
Message.setContentType(String contentType) |
Message |
Message.setEpoch(long epoch) |
Message |
Message.setHttpMethod(String httpMethod) |
Message |
Message.setIsDoingMTOM(boolean isDoingMTOM) |
Message |
Message.setIsDoingREST(boolean isDoingREST) |
Message |
Message.setIsDoingSwA(boolean isDoingSwA) |
Message |
Message.setMessage(byte[] message) |
Message |
Message.setMessage(ByteBuffer message) |
Message |
Message.setMessageId(String messageId) |
Message |
Message.setRequestURI(String requestURI) |
Message |
Message.setSoapAction(String soapAction) |
Message |
Message.setTransportHeaders(Map<String,String> transportHeaders) |
Modifier and Type | Method and Description |
---|---|
List<Message> |
CloudGatewayService.Iface.exchange(List<Message> src,
int size,
String token) |
List<Message> |
CloudGatewayService.Client.exchange(List<Message> src,
int size,
String token) |
List<Message> |
CloudGatewayService.AsyncClient.exchange_call.getResult() |
List<Message> |
CloudGatewayService.exchange_args.getSrc() |
Iterator<Message> |
CloudGatewayService.exchange_args.getSrcIterator() |
List<Message> |
CloudGatewayService.exchange_result.getSuccess() |
Iterator<Message> |
CloudGatewayService.exchange_result.getSuccessIterator() |
List<Message> |
CloudGatewayService.Client.recv_exchange() |
Modifier and Type | Method and Description |
---|---|
void |
CloudGatewayService.exchange_args.addToSrc(Message elem) |
void |
CloudGatewayService.exchange_result.addToSuccess(Message elem) |
int |
Message.compareTo(Message other) |
boolean |
Message.equals(Message that) |
Modifier and Type | Method and Description |
---|---|
List<Message> |
CloudGatewayService.Iface.exchange(List<Message> src,
int size,
String token) |
List<Message> |
CloudGatewayService.Client.exchange(List<Message> src,
int size,
String token) |
void |
CloudGatewayService.AsyncIface.exchange(List<Message> src,
int size,
String token,
org.apache.thrift.async.AsyncMethodCallback<CloudGatewayService.AsyncClient.exchange_call> resultHandler) |
void |
CloudGatewayService.AsyncClient.exchange(List<Message> src,
int size,
String token,
org.apache.thrift.async.AsyncMethodCallback<CloudGatewayService.AsyncClient.exchange_call> resultHandler) |
void |
CloudGatewayService.Client.send_exchange(List<Message> src,
int size,
String token) |
CloudGatewayService.exchange_args |
CloudGatewayService.exchange_args.setSrc(List<Message> src) |
CloudGatewayService.exchange_result |
CloudGatewayService.exchange_result.setSuccess(List<Message> success) |
Constructor and Description |
---|
Message(Message other)
Performs a deep copy on other.
|
Constructor and Description |
---|
CloudGatewayService.AsyncClient.exchange_call(List<Message> src,
int size,
String token,
org.apache.thrift.async.AsyncMethodCallback<CloudGatewayService.AsyncClient.exchange_call> resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
CloudGatewayService.exchange_args(List<Message> src,
int size,
String token) |
CloudGatewayService.exchange_result(List<Message> success,
NotAuthorizedException e) |
Copyright © 2017 WSO2. All rights reserved.