|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.synapse.transport.nhttp.HttpCoreNIOListener
public class HttpCoreNIOListener
NIO transport listener for Axis2 based on HttpCore and NIO extensions
Field Summary |
---|
Fields inherited from interface org.apache.axis2.transport.TransportListener |
---|
HOST_ADDRESS, PARAM_PORT |
Constructor Summary | |
---|---|
HttpCoreNIOListener()
|
Method Summary | |
---|---|
void |
destroy()
|
int |
getActiveConnectionsSize()
|
int |
getActiveThreadCount()
Returns the number of active threads processing messages |
double |
getAvgSizeReceived()
|
double |
getAvgSizeSent()
|
long |
getBytesReceived()
|
long |
getBytesSent()
|
EndpointReference |
getEPRForService(String serviceName,
String ip)
Return the EPR for the given service (implements deprecated method temporarily) |
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.NHttpServiceHandler handler,
SSLContext sslContext,
org.apache.http.impl.nio.reactor.SSLIOSessionHandler sslioSessionHandler,
org.apache.http.params.HttpParams params)
|
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(ConfigurationContext cfgCtx,
String wsdlEPRPrefix)
Return the EPR prefix for services made available over this transport |
protected String |
getServiceEPRPrefix(ConfigurationContext cfgCtx,
String host,
int port)
Return the EPR prefix for services made available over this transport |
SessionContext |
getSessionContext(MessageContext messageContext)
TODO: Return session context from transport, this is an improvement in axis2 1.2 and is not currently supported |
protected SSLContext |
getSSLContext(TransportInDescription transportIn)
Create the SSLContext to be used by this listener |
protected org.apache.http.impl.nio.reactor.SSLIOSessionHandler |
getSSLIOSessionHandler(TransportInDescription transportIn)
Create the SSL IO Session handler to be used by this listener |
long |
getTimeoutsReceiving()
|
long |
getTimeoutsSending()
|
void |
init(ConfigurationContext cfgCtx,
TransportInDescription transportIn)
Initialize the transport listener, and execute reactor in new seperate 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 maintenence |
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 |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public HttpCoreNIOListener()
Method Detail |
---|
protected org.apache.http.nio.reactor.IOEventDispatch getEventDispatch(org.apache.http.nio.NHttpServiceHandler handler, SSLContext sslContext, org.apache.http.impl.nio.reactor.SSLIOSessionHandler sslioSessionHandler, org.apache.http.params.HttpParams params)
public void init(ConfigurationContext cfgCtx, TransportInDescription transportIn) throws AxisFault
init
in interface TransportListener
cfgCtx
- the Axis2 configuration contexttransportIn
- the description of the http/s transport from Axis2 configuration
AxisFault
- on errorpublic int getActiveConnectionsSize()
protected String getServiceEPRPrefix(ConfigurationContext cfgCtx, String host, int port)
cfgCtx
- configuration context to retrieve the service context pathhost
- name of the hostport
- listening port
protected String getServiceEPRPrefix(ConfigurationContext cfgCtx, String wsdlEPRPrefix)
cfgCtx
- configuration context to retrieve the service context pathwsdlEPRPrefix
- specified wsdlPrefix
protected SSLContext getSSLContext(TransportInDescription transportIn) throws AxisFault
transportIn
- transport in description
AxisFault
- never thrownprotected org.apache.http.impl.nio.reactor.SSLIOSessionHandler getSSLIOSessionHandler(TransportInDescription transportIn) throws AxisFault
transportIn
- transport in descritption
AxisFault
- never thrownpublic void start() throws AxisFault
start
in interface TransportListener
AxisFault
public void stop() throws AxisFault
stop
in interface TransportListener
AxisFault
- on errorpublic void pause() throws AxisFault
pause
in interface org.apache.axis2.transport.base.ManagementSupport
AxisFault
public void resume() throws AxisFault
resume
in interface org.apache.axis2.transport.base.ManagementSupport
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 AxisFault
maintenenceShutdown
in interface org.apache.axis2.transport.base.ManagementSupport
millis
- a number of milliseconds to wait until pending requests are allowed to complete
AxisFault
public EndpointReference getEPRForService(String serviceName, String ip) throws AxisFault
getEPRForService
in interface TransportListener
AxisFault
public EndpointReference[] getEPRsForService(String serviceName, String ip) throws AxisFault
getEPRsForService
in interface TransportListener
serviceName
- name of the serviceip
- IP address
AxisFault
- on errorpublic SessionContext getSessionContext(MessageContext messageContext)
getSessionContext
in interface TransportListener
messageContext
- context to be used
public void destroy()
destroy
in interface 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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |