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

Class CGPollingTransportReceiver

  • All Implemented Interfaces:
    org.apache.axis2.transport.TransportListener
    public class CGPollingTransportReceiver
extends org.apache.axis2.transport.base.AbstractTransportListenerEx<CGPollingTransportEndpoint>
    CSG Polling Transport receiver implementation

    • Field Summary

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

        cfgCtx, config, isNonBlocking, log, metrics, state, useAxis2ThreadPool, workerPool

      • Fields inherited from interface org.apache.axis2.transport.TransportListener

        HOST_ADDRESS, PARAM_PORT

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected CGPollingTransportEndpoint createEndpoint()  
      protected void doInit()  
      CGAgentSubject getSubject()  
      protected void startEndpoint​(CGPollingTransportEndpoint csgThriftEndpoint)  
      protected void stopEndpoint​(CGPollingTransportEndpoint csgThriftEndpoint)  

      • Methods inherited from class org.apache.axis2.transport.base.AbstractTransportListenerEx

        getEndpoints, getEPRsForService, init, start, startListeningForService, stop, stopListeningForService

      • Methods inherited from class org.apache.axis2.transport.base.AbstractTransportListener

        createMessageContext, destroy, disableTransportForService, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getConfigurationContext, getEPRForService, getEPRsForService, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsCollector, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getSessionContext, getTimeoutsReceiving, getTimeoutsSending, getTransportInDescription, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resetStatistics, resume

    • Constructor Detail

      • CGPollingTransportReceiver

        public CGPollingTransportReceiver()