| java.lang.Object
 org.apache.synapse.transport.base.AbstractTransportListener
All known Subclasses: org.apache.synapse.transport.base.AbstractPollingTransportListener, org.apache.synapse.transport.amqp.AMQPListener, org.apache.synapse.transport.jms.JMSListener,
| AbstractTransportListener | | abstract public class AbstractTransportListener implements TransportListener(Code) | | |
| Inner Class :class GenericAxisObserver implements AxisObserver | |
| cfgCtx | | protected ConfigurationContext cfgCtx(Code) | | the axis2 configuration context
|
| engine | | protected AxisEngine engine(Code) | | an axis2 engine over the above configuration context to process messages
|
| isNonBlocking | | protected boolean isNonBlocking(Code) | | is this transport non-blocking?
|
| log | | protected Log log(Code) | | the reference to the actual commons logger to be used for log messages
|
| started | | protected boolean started(Code) | | is this transport started?
|
| transportName | | protected String transportName(Code) | | the name of the transport
|
| useAxis2ThreadPool | | protected boolean useAxis2ThreadPool(Code) | | use the thread pool available in the axis2 configuration context
|
| workerPool | | protected WorkerPool workerPool(Code) | | the thread pool to execute actual poll invocations
|
| AbstractTransportListener | | protected AbstractTransportListener()(Code) | | A constructor that makes subclasses pick up the correct logger
|
| createMessageContext | | public MessageContext createMessageContext()(Code) | | Create a new axis MessageContext for an incoming message through this transport
the newly created message context |
| destroy | | public void destroy()(Code) | | |
| getEPRForService | | public EndpointReference getEPRForService(String serviceName, String ip) throws AxisFault(Code) | | This is a deprecated method in Axis2 and this default implementation returns the first
result from the getEPRsForService() method
|
| getSessionContext | | public SessionContext getSessionContext(MessageContext messageContext)(Code) | | |
| handleIncomingMessage | | public void handleIncomingMessage(MessageContext msgCtx, Map trpHeaders, String soapAction, String contentType) throws AxisFault(Code) | | Process a new incoming message through the axis engine
Parameters:
msgCtx - the axis MessageContext
Parameters:
trpHeaders - the map containing transport level message headers
Parameters:
soapAction - the optional soap action or null
Parameters:
contentType - the optional content-type for the message |
| init | | public void init(ConfigurationContext cfgCtx, TransportInDescription transportIn) throws AxisFault(Code) | | Initialize the generic transport. Sets up the transport and the thread pool to be used
for message processing. Also creates an AxisObserver that gets notified of service
life cycle events for the transport to act on
Parameters:
cfgCtx - the axis configuration context
Parameters:
transportIn - the transport-in description
throws:
AxisFault - on error |
| setTransportName | | public void setTransportName(String transportName)(Code) | | |
| start | | public void start() throws AxisFault(Code) | | |
| startListeningForService | | abstract protected void startListeningForService(AxisService service)(Code) | | |
| stop | | public void stop() throws AxisFault(Code) | | |
| stopListeningForService | | abstract protected void stopListeningForService(AxisService service)(Code) | | |
|
|