E
- the type of protocol endpoint for this transportpublic abstract class AbstractTransportListenerEx<E extends ProtocolEndpoint> extends AbstractTransportListener
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
cfgCtx, config, isNonBlocking, log, metrics, state, useAxis2ThreadPool, workerPool
HOST_ADDRESS, PARAM_PORT
Constructor and Description |
---|
AbstractTransportListenerEx() |
Modifier and Type | Method and Description |
---|---|
protected abstract E |
createEndpoint() |
protected abstract void |
doInit()
Initialize the transport.
|
Collection<E> |
getEndpoints()
Get the collection of all protocol endpoints managed by this transport, including the
endpoint configured at the transport level.
|
EndpointReference[] |
getEPRsForService(String serviceName,
String ip)
Get the endpoint references for a given service.
|
void |
init(ConfigurationContext cfgCtx,
TransportInDescription transportIn)
Initialize the generic transport.
|
void |
start() |
protected abstract void |
startEndpoint(E endpoint) |
protected void |
startListeningForService(AxisService service) |
void |
stop() |
protected abstract void |
stopEndpoint(E endpoint) |
protected void |
stopListeningForService(AxisService service) |
createMessageContext, destroy, 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, getTransportInDescription, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resetStatistics, resume
public final void init(ConfigurationContext cfgCtx, TransportInDescription transportIn) throws AxisFault
AbstractTransportListener
init
in interface TransportListener
init
in class AbstractTransportListener
cfgCtx
- the axis configuration contexttransportIn
- the transport-in descriptionAxisFault
- on errorprotected abstract void doInit() throws AxisFault
AbstractTransportListener
and before the first endpoint is created, i.e. before the
first call to createEndpoint()
.AxisFault
public void start() throws AxisFault
start
in interface TransportListener
start
in class AbstractTransportListener
AxisFault
public void stop() throws AxisFault
stop
in interface TransportListener
stop
in class AbstractTransportListener
AxisFault
public EndpointReference[] getEPRsForService(String serviceName, String ip) throws AxisFault
TransportListener
getEPRsForService
in interface TransportListener
getEPRsForService
in class AbstractTransportListener
serviceName
- TODO: this is actually not simply the service name!ip
- The host name or IP address of the local host. The implementation should use
this information instead of InetAddress.getLocalHost()
.
The value of this parameter may be null
, in which case the
implementation should use Utils.getIpAddress(
org.apache.axis2.engine.AxisConfiguration)
.AxisFault
public final Collection<E> getEndpoints()
protected abstract E createEndpoint()
protected final void startListeningForService(AxisService service) throws AxisFault
startListeningForService
in class AbstractTransportListener
AxisFault
protected final void stopListeningForService(AxisService service)
stopListeningForService
in class AbstractTransportListener
protected abstract void stopEndpoint(E endpoint)
Copyright © 2004–2018 The Apache Software Foundation. All rights reserved.