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
,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>
AProtocol
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.
-
-
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 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
-
-
-
-
Method Detail
-
doInit
protected void doInit() throws org.apache.axis2.AxisFault
- Overrides:
doInit
in classorg.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 classorg.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
- Throws:
IOException
-
doCreateEndpoint
protected PipeEndpoint doCreateEndpoint()
- Specified by:
doCreateEndpoint
in classorg.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
-
-