|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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
public class PipeListener
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:
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 |
---|
public PipeListener()
Method Detail |
---|
public void init(ConfigurationContext cfgCtx, TransportInDescription transportIn) throws AxisFault
init
in interface TransportListener
init
in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
AxisFault
protected PipeDispatcher createDispatcher(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback) throws IOException
createDispatcher
in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
IOException
protected PipeEndpoint doCreateEndpoint()
doCreateEndpoint
in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |