Class CGTransportSender
- java.lang.Object
-
- org.apache.axis2.handlers.AbstractHandler
-
- org.apache.axis2.transport.base.AbstractTransportSender
-
- org.wso2.carbon.cloud.gateway.transport.CGTransportSender
-
- All Implemented Interfaces:
org.apache.axis2.engine.Handler
,org.apache.axis2.transport.TransportSender
public class CGTransportSender extends org.apache.axis2.transport.base.AbstractTransportSender
The CGTransport sender implementation. For one way messages this will just send the message to to the Thrift server's request message buffer using an in memory copy and for two way messages a semaphore will be blocked the current thread of execution until a response is received
-
-
Constructor Summary
Constructors Constructor Description CGTransportSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanup(org.apache.axis2.context.MessageContext msgContext)
void
init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut)
void
sendMessage(org.apache.axis2.context.MessageContext msgContext, String targetEPR, org.apache.axis2.transport.OutTransportInfo outTransportInfo)
void
stop()
-
Methods inherited from class org.apache.axis2.transport.base.AbstractTransportSender
createResponseMessageContext, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, getTransportName, handleException, handleException, handleIncomingMessage, invoke, logException, maintenenceShutdown, pause, resetStatistics, resume, waitForSynchronousResponse
-
Methods inherited from class org.apache.axis2.handlers.AbstractHandler
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toString
-
-
-
-
Method Detail
-
init
public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
- Specified by:
init
in interfaceorg.apache.axis2.transport.TransportSender
- Overrides:
init
in classorg.apache.axis2.transport.base.AbstractTransportSender
- Throws:
org.apache.axis2.AxisFault
-
cleanup
public void cleanup(org.apache.axis2.context.MessageContext msgContext) throws org.apache.axis2.AxisFault
- Specified by:
cleanup
in interfaceorg.apache.axis2.transport.TransportSender
- Overrides:
cleanup
in classorg.apache.axis2.transport.base.AbstractTransportSender
- Throws:
org.apache.axis2.AxisFault
-
stop
public void stop()
- Specified by:
stop
in interfaceorg.apache.axis2.transport.TransportSender
- Overrides:
stop
in classorg.apache.axis2.transport.base.AbstractTransportSender
-
sendMessage
public void sendMessage(org.apache.axis2.context.MessageContext msgContext, String targetEPR, org.apache.axis2.transport.OutTransportInfo outTransportInfo) throws org.apache.axis2.AxisFault
- Specified by:
sendMessage
in classorg.apache.axis2.transport.base.AbstractTransportSender
- Throws:
org.apache.axis2.AxisFault
-
-