org.apache.axis2.transport.base
Class AbstractTransportListenerEx<E extends ProtocolEndpoint>

java.lang.Object
  extended by org.apache.axis2.transport.base.AbstractTransportListener
      extended by org.apache.axis2.transport.base.AbstractTransportListenerEx<E>
Type Parameters:
E - the type of protocol endpoint for this transport
All Implemented Interfaces:
org.apache.axis2.transport.TransportListener
Direct Known Subclasses:
AbstractDatagramTransportListener, AbstractPollingTransportListener, JMSListener

public abstract class AbstractTransportListenerEx<E extends ProtocolEndpoint>
extends AbstractTransportListener

Partial implementation of AbstractTransportListener with a higher level of abstraction. It maintains the mapping between services and protocol specific endpoints.

Note: the intention is to eventually merge the code in this class into AbstractTransportListener


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
AbstractTransportListenerEx()
           
 
Method Summary
protected abstract  E createEndpoint()
           
 void destroy()
           
 java.util.Collection<E> getEndpoints()
           
 org.apache.axis2.addressing.EndpointReference[] getEPRsForService(java.lang.String serviceName, java.lang.String ip)
           
 void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription transportIn)
          Initialize the generic transport.
protected abstract  void startEndpoint(E endpoint)
           
protected  void startListeningForService(org.apache.axis2.description.AxisService service)
           
protected abstract  void stopEndpoint(E endpoint)
           
protected  void stopListeningForService(org.apache.axis2.description.AxisService service)
           
 
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

AbstractTransportListenerEx

public AbstractTransportListenerEx()
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 AbstractTransportListener
Parameters:
cfgCtx - the axis configuration context
transportIn - the transport-in description
Throws:
org.apache.axis2.AxisFault - on error

destroy

public void destroy()
Specified by:
destroy in interface org.apache.axis2.transport.TransportListener
Overrides:
destroy in class AbstractTransportListener

getEPRsForService

public org.apache.axis2.addressing.EndpointReference[] getEPRsForService(java.lang.String serviceName,
                                                                         java.lang.String ip)
                                                                  throws org.apache.axis2.AxisFault
Specified by:
getEPRsForService in interface org.apache.axis2.transport.TransportListener
Overrides:
getEPRsForService in class AbstractTransportListener
Throws:
org.apache.axis2.AxisFault

getEndpoints

public final java.util.Collection<E> getEndpoints()

createEndpoint

protected abstract E createEndpoint()

startListeningForService

protected final void startListeningForService(org.apache.axis2.description.AxisService service)
                                       throws org.apache.axis2.AxisFault
Specified by:
startListeningForService in class AbstractTransportListener
Throws:
org.apache.axis2.AxisFault

startEndpoint

protected abstract void startEndpoint(E endpoint)
                               throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault

stopListeningForService

protected final void stopListeningForService(org.apache.axis2.description.AxisService service)
Specified by:
stopListeningForService in class AbstractTransportListener

stopEndpoint

protected abstract void stopEndpoint(E endpoint)


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