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

java.lang.Object
  extended by org.apache.axis2.transport.base.AbstractTransportListener
      extended by org.apache.axis2.transport.base.AbstractTransportListenerEx<E>
          extended by org.apache.axis2.transport.base.datagram.AbstractDatagramTransportListener<E>
All Implemented Interfaces:
org.apache.axis2.transport.TransportListener
Direct Known Subclasses:
UDPListener

public abstract class AbstractDatagramTransportListener<E extends DatagramEndpoint>
extends AbstractTransportListenerEx<E>


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
AbstractDatagramTransportListener()
           
 
Method Summary
protected abstract  DatagramDispatcher<E> createDispatcher(DatagramDispatcherCallback callback)
           
protected  E createEndpoint()
           
 void destroy()
           
protected abstract  E doCreateEndpoint()
           
 void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription transportIn)
          Initialize the generic transport.
protected  void startEndpoint(E endpoint)
           
protected  void stopEndpoint(E endpoint)
           
 
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
 

Constructor Detail

AbstractDatagramTransportListener

public AbstractDatagramTransportListener()
Method Detail

init

public void init(org.apache.axis2.context.ConfigurationContext cfgCtx,
                 org.apache.axis2.description.TransportInDescription transportIn)
          throws org.apache.axis2.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 org.apache.axis2.transport.TransportListener
Overrides:
init in class AbstractTransportListenerEx<E extends DatagramEndpoint>
Parameters:
cfgCtx - the axis configuration context
transportIn - the transport-in description
Throws:
org.apache.axis2.AxisFault - on error

createEndpoint

protected final E createEndpoint()
Specified by:
createEndpoint in class AbstractTransportListenerEx<E extends DatagramEndpoint>

doCreateEndpoint

protected abstract E doCreateEndpoint()

startEndpoint

protected void startEndpoint(E endpoint)
                      throws org.apache.axis2.AxisFault
Specified by:
startEndpoint in class AbstractTransportListenerEx<E extends DatagramEndpoint>
Throws:
org.apache.axis2.AxisFault

stopEndpoint

protected void stopEndpoint(E endpoint)
Specified by:
stopEndpoint in class AbstractTransportListenerEx<E extends DatagramEndpoint>

destroy

public void destroy()
Specified by:
destroy in interface org.apache.axis2.transport.TransportListener
Overrides:
destroy in class AbstractTransportListenerEx<E extends DatagramEndpoint>

createDispatcher

protected abstract DatagramDispatcher<E> createDispatcher(DatagramDispatcherCallback callback)
                                                                            throws java.io.IOException
Throws:
java.io.IOException


Copyright © 2004-2009 The Apache Software Foundation. All Rights Reserved.