org.apache.synapse.transport.pipe
Class PipeListener

java.lang.Object
  org.apache.axis2.transport.base.AbstractTransportListener
      org.apache.axis2.transport.base.AbstractTransportListenerEx<E>
          org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
              org.apache.synapse.transport.pipe.PipeListener

All Implemented Interfaces:

org.apache.axis2.transport.base.ManagementSupport, 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

PipeListener()

Method Summary

protected PipeDispatcher	createDispatcher(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback)
protected PipeEndpoint	doCreateEndpoint()
void	init(ConfigurationContext cfgCtx, TransportInDescription transportIn)

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, startListeningForService, 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, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resetStatistics, resume, start, stop

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 Detail

PipeListener

public PipeListener()

Method Detail

init

public void init(ConfigurationContext cfgCtx,
                 TransportInDescription transportIn)
          throws AxisFault

Specified by:

init in interface TransportListener

Overrides:

init in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>

Throws:

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>