public abstract class AbstractPollingTransportListener<T extends AbstractPollTableEntry> extends AbstractTransportListenerEx<T>
cfgCtx, config, isNonBlocking, log, metrics, state, useAxis2ThreadPool, workerPool
HOST_ADDRESS, PARAM_PORT
Constructor and Description |
---|
AbstractPollingTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected void |
doInit()
Initialize the transport.
|
void |
maintenenceShutdown(long millis)
Stop processing new messages, and wait the specified maximum time for in-flight
requests to complete before a controlled shutdown for maintenence
|
protected void |
onPollCompletion(T entry) |
void |
pause()
Pause the listener - Stop accepting/processing new messages, but continues processing existing
messages until they complete.
|
protected abstract void |
poll(T entry) |
protected void |
processFailure(String msg,
Exception e,
T entry)
method to log a failure to the log file and to update the last poll status and time
|
void |
resume()
Resume the lister - Brings the lister into active mode back from a paused state
|
protected void |
startEndpoint(T endpoint) |
protected void |
stopEndpoint(T endpoint) |
createEndpoint, getEndpoints, getEPRsForService, init, start, startListeningForService, stop, stopListeningForService
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, getTransportInDescription, getTransportName, handleException, handleIncomingMessage, logException, resetStatistics
protected void doInit() throws AxisFault
AbstractTransportListenerEx
AbstractTransportListener
and before the first endpoint is created, i.e. before the
first call to AbstractTransportListenerEx.createEndpoint()
.doInit
in class AbstractTransportListenerEx<T extends AbstractPollTableEntry>
AxisFault
public void destroy()
destroy
in interface TransportListener
destroy
in class AbstractTransportListener
protected void startEndpoint(T endpoint) throws AxisFault
startEndpoint
in class AbstractTransportListenerEx<T extends AbstractPollTableEntry>
AxisFault
protected void stopEndpoint(T endpoint)
stopEndpoint
in class AbstractTransportListenerEx<T extends AbstractPollTableEntry>
protected abstract void poll(T entry)
protected void onPollCompletion(T entry)
protected void processFailure(String msg, Exception e, T entry)
msg
- text for the log messagee
- optional exception encountered or nullentry
- the PollTableEntrypublic void pause() throws AxisFault
pause
in class AbstractTransportListener
AxisFault
- on errorpublic void resume() throws AxisFault
resume
in class AbstractTransportListener
AxisFault
- on errorpublic void maintenenceShutdown(long millis) throws AxisFault
maintenenceShutdown
in class AbstractTransportListener
millis
- a number of milliseconds to wait until pending requests are allowed to completeAxisFault
- on errorCopyright © 2004–2018 The Apache Software Foundation. All rights reserved.