org.apache.axis2.transport.base
Class AbstractTransportListenerEx<E extends ProtocolEndpoint>
java.lang.Object
org.apache.axis2.transport.base.AbstractTransportListener
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
Fields inherited from interface org.apache.axis2.transport.TransportListener |
HOST_ADDRESS, PARAM_PORT |
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 |
AbstractTransportListenerEx
public AbstractTransportListenerEx()
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 contexttransportIn
- 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.