public class HttpCoreNIOListener extends Object implements org.apache.axis2.transport.TransportListener, org.apache.axis2.transport.base.ManagementSupport
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[] |
getEPRsForService(String serviceName,
String ip)
Return the EPRs for the given service over this transport
|
protected org.apache.http.nio.reactor.IOEventDispatch |
getEventDispatch(org.apache.http.nio.NHttpServerEventHandler handler,
SSLContext sslContext,
org.apache.http.nio.reactor.ssl.SSLSetupHandler setupHandler,
org.apache.http.config.ConnectionConfig config) |
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 requests 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
|
protected SSLContext |
getSSLContext(org.apache.axis2.description.TransportInDescription transportIn)
Create the SSLContext to be used by this listener
|
protected org.apache.http.nio.reactor.ssl.SSLSetupHandler |
getSSLIOSessionHandler(org.apache.axis2.description.TransportInDescription transportIn)
Create the SSL IO Session handler to be used by this listener
|
long |
getTimeoutsReceiving() |
long |
getTimeoutsSending() |
void |
init(org.apache.axis2.context.ConfigurationContext cfgCtx,
org.apache.axis2.description.TransportInDescription transportIn)
Initialize the transport listener, and execute reactor in new separate thread
|
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 maintenance
|
void |
pause()
Pause the listener - Stops accepting new connections, but continues processing existing
connections until they complete.
|
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
|
protected org.apache.http.nio.reactor.IOEventDispatch getEventDispatch(org.apache.http.nio.NHttpServerEventHandler handler, SSLContext sslContext, org.apache.http.nio.reactor.ssl.SSLSetupHandler setupHandler, org.apache.http.config.ConnectionConfig config)
public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, 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 wsdlPrefixprotected SSLContext getSSLContext(org.apache.axis2.description.TransportInDescription transportIn) throws org.apache.axis2.AxisFault
transportIn
- transport in descriptionorg.apache.axis2.AxisFault
- never thrownprotected org.apache.http.nio.reactor.ssl.SSLSetupHandler getSSLIOSessionHandler(org.apache.axis2.description.TransportInDescription transportIn) throws org.apache.axis2.AxisFault
transportIn
- transport in descritptionorg.apache.axis2.AxisFault
- never thrownpublic 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 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[] 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
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.