public class PipeListener extends org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint> implements org.apache.axis2.transport.base.ManagementSupport
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:
Constructor and Description |
---|
PipeListener() |
Modifier and Type | Method and Description |
---|---|
protected PipeDispatcher |
createDispatcher(org.apache.axis2.transport.base.datagram.DatagramDispatcherCallback callback) |
protected PipeEndpoint |
doCreateEndpoint() |
protected void |
doInit() |
createEndpoint, destroy, startEndpoint, stopEndpoint
getEndpoints, getEPRsForService, init, start, startListeningForService, stop, stopListeningForService
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, maintenenceShutdown, pause, resetStatistics, resume
protected void doInit() throws org.apache.axis2.AxisFault
doInit
in class org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<PipeEndpoint>
org.apache.axis2.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>
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.