org.apache.synapse.transport.base.datagram
Class AbstractDatagramTransportListener<E extends DatagramEndpoint>

java.lang.Object
  org.apache.synapse.transport.base.AbstractTransportListener
      org.apache.synapse.transport.base.datagram.AbstractDatagramTransportListener<E>

All Implemented Interfaces:

TransportListener

Direct Known Subclasses:

PipeListener, UDPListener

public abstract class AbstractDatagramTransportListener<E extends DatagramEndpoint>
extends AbstractTransportListener

Field Summary

Fields inherited from class org.apache.synapse.transport.base.AbstractTransportListener

cfgCtx, engine, isNonBlocking, log, metrics, state, transportName, useAxis2ThreadPool, workerPool

Fields inherited from interface org.apache.axis2.transport.TransportListener

HOST_ADDRESS, PARAM_PORT

Constructor Summary

AbstractDatagramTransportListener()

Method Summary

protected abstract DatagramDispatcher<E>	createDispatcher(DatagramDispatcherCallback callback)
protected abstract E	createEndpoint(AxisService service)
void	destroy()
EndpointReference[]	getEPRsForService(String serviceName, String ip)
void	init(ConfigurationContext cfgCtx, TransportInDescription transportIn) Initialize the generic transport.
protected void	startListeningForService(AxisService service)
protected void	stopListeningForService(AxisService service)

Methods inherited from class org.apache.synapse.transport.base.AbstractTransportListener

createMessageContext, disableTransportForService, getActiveThreadCount, getBytesReceived, getBytesSent, getEPRForService, getFaultsReceiving, getFaultsSending, getMessagesReceived, getMessagesSent, getMetricsCollector, getQueueSize, getSessionContext, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resume, setTransportName, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractDatagramTransportListener

public AbstractDatagramTransportListener()

Method Detail

init

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

Description copied from class: AbstractTransportListener

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

Specified by:

init in interface TransportListener

Overrides:

init in class AbstractTransportListener

Parameters:

cfgCtx - the axis configuration context

transportIn - the transport-in description

Throws:

AxisFault - on error

startListeningForService

protected void startListeningForService(AxisService service)

Specified by:

startListeningForService in class AbstractTransportListener

stopListeningForService

protected void stopListeningForService(AxisService service)

Specified by:

stopListeningForService in class AbstractTransportListener

destroy

public void destroy()

Specified by:

destroy in interface TransportListener

Overrides:

destroy in class AbstractTransportListener

getEPRsForService

public EndpointReference[] getEPRsForService(String serviceName,
                                             String ip)
                                      throws AxisFault

Throws:

AxisFault

createDispatcher

protected abstract DatagramDispatcher<E> createDispatcher(DatagramDispatcherCallback callback)
                                                                            throws IOException

Throws:

IOException

createEndpoint

protected abstract E createEndpoint(AxisService service)
                                                      throws AxisFault

Throws:

AxisFault