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

Class 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

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler

        org.apache.axis2.engine.Handler.InvocationResponse

    • Field Summary

      • Fields inherited from class org.apache.axis2.transport.base.AbstractTransportSender

        cfgCtx, metrics

      • Fields inherited from class org.apache.axis2.handlers.AbstractHandler

        handlerDesc

    • 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

      • Methods inherited from interface org.apache.axis2.engine.Handler

        cleanup, flowComplete, getHandlerDesc, getName, getParameter, init

    • Constructor Detail

      • CGTransportSender

        public CGTransportSender()

    • 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 interface org.apache.axis2.transport.TransportSender
        Overrides:
        init in class org.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 interface org.apache.axis2.transport.TransportSender
        Overrides:
        cleanup in class org.apache.axis2.transport.base.AbstractTransportSender
        Throws:
        org.apache.axis2.AxisFault

      • stop

        public void stop()
        Specified by:
        stop in interface org.apache.axis2.transport.TransportSender
        Overrides:
        stop in class org.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 class org.apache.axis2.transport.base.AbstractTransportSender
        Throws:
        org.apache.axis2.AxisFault