Package org.apache.synapse.transport.pipe

Class PipeListener

java.lang.Object
org.apache.axis2.transport.base.AbstractTransportListener
org.apache.axis2.transport.base.AbstractTransportListenerEx<PipeEndpoint>
org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
org.apache.synapse.transport.pipe.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

    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 class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    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 Details

    • PipeListener

      public PipeListener()

  • Method Details

    • 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>