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.AxisFault
protected ServerConnFactoryBuilder initConnFactoryBuilder(org.apache.axis2.description.TransportInDescription transportIn, org.apache.http.HttpHost host) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public 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.TransportListener
org.apache.axis2.AxisFault
public void stop() throws org.apache.axis2.AxisFault
stop
in interface org.apache.axis2.transport.TransportListener
org.apache.axis2.AxisFault
- on errorpublic void pause() throws org.apache.axis2.AxisFault
pause
in interface org.apache.axis2.transport.base.ManagementSupport
org.apache.axis2.AxisFault
public void resume() throws org.apache.axis2.AxisFault
resume
in interface org.apache.axis2.transport.base.ManagementSupport
org.apache.axis2.AxisFault
public void reload(org.apache.axis2.description.TransportInDescription transportIn) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void reloadSpecificEndpoints(org.apache.axis2.description.TransportInDescription transportIn) throws org.apache.axis2.AxisFault
transportIn
- TransportInDescription of new configurationorg.apache.axis2.AxisFault
public int getActiveThreadCount()
getActiveThreadCount
in interface org.apache.axis2.transport.base.ManagementSupport
public int getQueueSize()
getQueueSize
in interface org.apache.axis2.transport.base.ManagementSupport
public void maintenenceShutdown(long millis) throws org.apache.axis2.AxisFault
maintenenceShutdown
in interface org.apache.axis2.transport.base.ManagementSupport
millis
- a number of milliseconds to wait until pending requests are allowed to completeorg.apache.axis2.AxisFault
public org.apache.axis2.addressing.EndpointReference getEPRForService(String serviceName, String ip) throws org.apache.axis2.AxisFault
getEPRForService
in interface org.apache.axis2.transport.TransportListener
org.apache.axis2.AxisFault
public org.apache.axis2.addressing.EndpointReference[] getEPRsForService(String serviceName, String ip) throws org.apache.axis2.AxisFault
getEPRsForService
in interface org.apache.axis2.transport.TransportListener
serviceName
- 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.TransportListener
messageContext
- context to be usedpublic void destroy()
destroy
in interface org.apache.axis2.transport.TransportListener
public long getMessagesReceived()
getMessagesReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getFaultsReceiving()
getFaultsReceiving
in interface org.apache.axis2.transport.base.ManagementSupport
public long getBytesReceived()
getBytesReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMessagesSent()
getMessagesSent
in interface org.apache.axis2.transport.base.ManagementSupport
public long getFaultsSending()
getFaultsSending
in interface org.apache.axis2.transport.base.ManagementSupport
public long getBytesSent()
getBytesSent
in interface org.apache.axis2.transport.base.ManagementSupport
public long getTimeoutsReceiving()
getTimeoutsReceiving
in interface org.apache.axis2.transport.base.ManagementSupport
public long getTimeoutsSending()
getTimeoutsSending
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMinSizeReceived()
getMinSizeReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMaxSizeReceived()
getMaxSizeReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public double getAvgSizeReceived()
getAvgSizeReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMinSizeSent()
getMinSizeSent
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMaxSizeSent()
getMaxSizeSent
in interface org.apache.axis2.transport.base.ManagementSupport
public double getAvgSizeSent()
getAvgSizeSent
in interface org.apache.axis2.transport.base.ManagementSupport
public Map getResponseCodeTable()
getResponseCodeTable
in interface org.apache.axis2.transport.base.ManagementSupport
public void resetStatistics()
resetStatistics
in interface org.apache.axis2.transport.base.ManagementSupport
public long getLastResetTime()
getLastResetTime
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMetricsWindow()
getMetricsWindow
in interface org.apache.axis2.transport.base.ManagementSupport
public void reloadDynamicSSLConfig(org.apache.axis2.description.TransportInDescription transportInDescription) throws org.apache.axis2.AxisFault
transportInDescription
- TransportInDescription of the configurationorg.apache.axis2.AxisFault
Copyright © 2005–2019 Apache Software Foundation. All rights reserved.