Class PipeListener

  • All Implemented Interfaces:
    org.apache.axis2.transport.base.ManagementSupport, org.apache.axis2.transport.TransportListener

    public class PipeListener
    extends org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
    implements org.apache.axis2.transport.base.ManagementSupport
    Transport listener for UNIX pipes.

    The pipe transport listener can be enabled in the Axis configuration as follows:

     <transportReceiver name="pipe" class="org.apache.synapse.transport.pipe.PipeListener">
       <parameter name="protocol">...</parameter>
       other protocol specific parameters
     </transportReceiver>
    A Protocol implementation must be specified using the protocol parameter. This determines how the stream is decomposed into individual messages. The configuration must be completed by other parameters as required by the protocol implementation.

    In addition, services accepting messages using this transport must be configured with the following parameters:

    transport.pipe.name
    The name (path) of the UNIX pipe to read from (required).
    transport.pipe.contentType
    The content type of the messages received (required). This setting is used to select the appropriate message builder.
    • 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
    • Constructor Summary

      Constructors 
      Constructor Description
      PipeListener()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected PipeDispatcher createDispatcher​(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback)  
      protected PipeEndpoint doCreateEndpoint()  
      protected void doInit()  
      • Methods inherited from class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener

        createEndpoint, destroy, startEndpoint, stopEndpoint
      • 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, 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
      • Methods inherited from interface org.apache.axis2.transport.base.ManagementSupport

        getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, maintenenceShutdown, pause, resetStatistics, resume
    • Constructor Detail

      • PipeListener

        public PipeListener()
    • Method Detail

      • doInit

        protected void doInit()
                       throws org.apache.axis2.AxisFault
        Overrides:
        doInit in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
        Throws:
        org.apache.axis2.AxisFault
      • createDispatcher

        protected PipeDispatcher createDispatcher​(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback)
                                           throws IOException
        Specified by:
        createDispatcher in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
        Throws:
        IOException
      • doCreateEndpoint

        protected PipeEndpoint doCreateEndpoint()
        Specified by:
        doCreateEndpoint in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>