public class HttpCoreNIOListener extends Object implements org.apache.axis2.transport.TransportListener, org.apache.axis2.transport.base.ManagementSupport
| Modifier and Type | Field and Description |
|---|---|
static long |
ACTIVE_CONNECTION_MONITOR_DELAY
Delay for ActiveConnectionMonitor
|
| Constructor and Description |
|---|
HttpCoreNIOListener() |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy() |
int |
getActiveConnectionsSize() |
int |
getActiveThreadCount()
Returns the number of active threads processing messages
|
double |
getAvgSizeReceived() |
double |
getAvgSizeSent() |
long |
getBytesReceived() |
long |
getBytesSent() |
org.apache.axis2.addressing.EndpointReference |
getEPRForService(String serviceName,
String ip)
Return the EPR for the given service (implements deprecated method temporarily)
|
org.apache.axis2.addressing.EndpointReference[] |
getEPRsForService(String serviceName,
String ip)
Return the EPRs for the given service over this transport
|
long |
getFaultsReceiving() |
long |
getFaultsSending() |
long |
getLastResetTime() |
long |
getMaxSizeReceived() |
long |
getMaxSizeSent() |
long |
getMessagesReceived() |
long |
getMessagesSent() |
long |
getMetricsWindow() |
long |
getMinSizeReceived() |
long |
getMinSizeSent() |
int |
getQueueSize()
Returns the number of requestes queued in the thread pool
|
Map |
getResponseCodeTable() |
protected String |
getServiceEPRPrefix(org.apache.axis2.context.ConfigurationContext cfgCtx,
String wsdlEPRPrefix)
Return the EPR prefix for services made available over this transport
|
protected String |
getServiceEPRPrefix(org.apache.axis2.context.ConfigurationContext cfgCtx,
String host,
int port)
Return the EPR prefix for services made available over this transport
|
org.apache.axis2.context.SessionContext |
getSessionContext(org.apache.axis2.context.MessageContext messageContext)
TODO: Return session context from transport, this is an improvement in axis2 1.2 and
is not currently supported
|
long |
getTimeoutsReceiving() |
long |
getTimeoutsSending() |
void |
init(org.apache.axis2.context.ConfigurationContext ctx,
org.apache.axis2.description.TransportInDescription transportIn)
Initialize the transport listener, and execute reactor in new separate thread
|
protected ServerConnFactoryBuilder |
initConnFactoryBuilder(org.apache.axis2.description.TransportInDescription transportIn,
org.apache.http.HttpHost host) |
protected ServerConnFactoryBuilder |
initConnFactoryBuilder(org.apache.axis2.description.TransportInDescription transportIn,
org.apache.http.HttpHost host,
org.apache.axis2.context.ConfigurationContext configurationContext) |
protected Scheme |
initScheme() |
void |
maintenenceShutdown(long millis)
Stop accepting new connections, and wait the maximum specified time for in-flight
requests to complete before a controlled shutdown for maintenence
|
void |
pause()
Pause the listener - Stops accepting new connections, but continues processing existing
connections until they complete.
|
void |
reload(org.apache.axis2.description.TransportInDescription transportIn) |
void |
reloadDynamicSSLConfig(org.apache.axis2.description.TransportInDescription transportInDescription)
Reload SSL profiles and reset connections
|
void |
reloadSpecificEndpoints(org.apache.axis2.description.TransportInDescription transportIn)
Restart specific endpoints which was updated by new configurations
|
void |
resetStatistics() |
void |
resume()
Resume the lister - Brings the lister into active mode back from a paused state
|
void |
start()
Start the transport listener.
|
void |
stop()
Stop the listener
|
public static final long ACTIVE_CONNECTION_MONITOR_DELAY
protected Scheme initScheme()
protected ServerConnFactoryBuilder initConnFactoryBuilder(org.apache.axis2.description.TransportInDescription transportIn, org.apache.http.HttpHost host, org.apache.axis2.context.ConfigurationContext configurationContext) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFaultprotected ServerConnFactoryBuilder initConnFactoryBuilder(org.apache.axis2.description.TransportInDescription transportIn, org.apache.http.HttpHost host) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFaultpublic void init(org.apache.axis2.context.ConfigurationContext ctx,
org.apache.axis2.description.TransportInDescription transportIn)
throws org.apache.axis2.AxisFault
init in interface org.apache.axis2.transport.TransportListener"cfgCtx" - the Axis2 configuration contexttransportIn - the description of the http/s transport from Axis2 configurationorg.apache.axis2.AxisFault - on errorpublic int getActiveConnectionsSize()
protected String getServiceEPRPrefix(org.apache.axis2.context.ConfigurationContext cfgCtx, String host, int port)
cfgCtx - configuration context to retrieve the service context pathhost - name of the hostport - listening portprotected String getServiceEPRPrefix(org.apache.axis2.context.ConfigurationContext cfgCtx, String wsdlEPRPrefix)
cfgCtx - configuration context to retrieve the service context pathwsdlEPRPrefix - specified wsdlPrefixpublic void start()
throws org.apache.axis2.AxisFault
start in interface org.apache.axis2.transport.TransportListenerorg.apache.axis2.AxisFaultpublic void stop()
throws org.apache.axis2.AxisFault
stop in interface org.apache.axis2.transport.TransportListenerorg.apache.axis2.AxisFault - on errorpublic void pause()
throws org.apache.axis2.AxisFault
pause in interface org.apache.axis2.transport.base.ManagementSupportorg.apache.axis2.AxisFaultpublic void resume()
throws org.apache.axis2.AxisFault
resume in interface org.apache.axis2.transport.base.ManagementSupportorg.apache.axis2.AxisFaultpublic void reload(org.apache.axis2.description.TransportInDescription transportIn)
throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFaultpublic void reloadSpecificEndpoints(org.apache.axis2.description.TransportInDescription transportIn)
throws org.apache.axis2.AxisFault
transportIn - TransportInDescription of new configurationorg.apache.axis2.AxisFaultpublic int getActiveThreadCount()
getActiveThreadCount in interface org.apache.axis2.transport.base.ManagementSupportpublic int getQueueSize()
getQueueSize in interface org.apache.axis2.transport.base.ManagementSupportpublic void maintenenceShutdown(long millis)
throws org.apache.axis2.AxisFault
maintenenceShutdown in interface org.apache.axis2.transport.base.ManagementSupportmillis - a number of milliseconds to wait until pending requests are allowed to completeorg.apache.axis2.AxisFaultpublic org.apache.axis2.addressing.EndpointReference getEPRForService(String serviceName, String ip) throws org.apache.axis2.AxisFault
getEPRForService in interface org.apache.axis2.transport.TransportListenerorg.apache.axis2.AxisFaultpublic org.apache.axis2.addressing.EndpointReference[] getEPRsForService(String serviceName, String ip) throws org.apache.axis2.AxisFault
getEPRsForService in interface org.apache.axis2.transport.TransportListenerserviceName - name of the serviceip - IP addressorg.apache.axis2.AxisFault - on errorpublic org.apache.axis2.context.SessionContext getSessionContext(org.apache.axis2.context.MessageContext messageContext)
getSessionContext in interface org.apache.axis2.transport.TransportListenermessageContext - context to be usedpublic void destroy()
destroy in interface org.apache.axis2.transport.TransportListenerpublic long getMessagesReceived()
getMessagesReceived in interface org.apache.axis2.transport.base.ManagementSupportpublic long getFaultsReceiving()
getFaultsReceiving in interface org.apache.axis2.transport.base.ManagementSupportpublic long getBytesReceived()
getBytesReceived in interface org.apache.axis2.transport.base.ManagementSupportpublic long getMessagesSent()
getMessagesSent in interface org.apache.axis2.transport.base.ManagementSupportpublic long getFaultsSending()
getFaultsSending in interface org.apache.axis2.transport.base.ManagementSupportpublic long getBytesSent()
getBytesSent in interface org.apache.axis2.transport.base.ManagementSupportpublic long getTimeoutsReceiving()
getTimeoutsReceiving in interface org.apache.axis2.transport.base.ManagementSupportpublic long getTimeoutsSending()
getTimeoutsSending in interface org.apache.axis2.transport.base.ManagementSupportpublic long getMinSizeReceived()
getMinSizeReceived in interface org.apache.axis2.transport.base.ManagementSupportpublic long getMaxSizeReceived()
getMaxSizeReceived in interface org.apache.axis2.transport.base.ManagementSupportpublic double getAvgSizeReceived()
getAvgSizeReceived in interface org.apache.axis2.transport.base.ManagementSupportpublic long getMinSizeSent()
getMinSizeSent in interface org.apache.axis2.transport.base.ManagementSupportpublic long getMaxSizeSent()
getMaxSizeSent in interface org.apache.axis2.transport.base.ManagementSupportpublic double getAvgSizeSent()
getAvgSizeSent in interface org.apache.axis2.transport.base.ManagementSupportpublic Map getResponseCodeTable()
getResponseCodeTable in interface org.apache.axis2.transport.base.ManagementSupportpublic void resetStatistics()
resetStatistics in interface org.apache.axis2.transport.base.ManagementSupportpublic long getLastResetTime()
getLastResetTime in interface org.apache.axis2.transport.base.ManagementSupportpublic long getMetricsWindow()
getMetricsWindow in interface org.apache.axis2.transport.base.ManagementSupportpublic void reloadDynamicSSLConfig(org.apache.axis2.description.TransportInDescription transportInDescription)
throws org.apache.axis2.AxisFault
transportInDescription - TransportInDescription of the configurationorg.apache.axis2.AxisFaultCopyright © 2005–2019 Apache Software Foundation. All rights reserved.