org.wso2.carbon.utils.transport
Class AbstractTransportListener

java.lang.Object
  org.wso2.carbon.utils.transport.AbstractTransportListener

All Implemented Interfaces:

org.apache.axis2.transport.base.ManagementSupport, org.apache.axis2.transport.TransportListener

public abstract class AbstractTransportListener
extends Object
implements org.apache.axis2.transport.TransportListener, org.apache.axis2.transport.base.ManagementSupport

This class will provide basic functionality to write http and https listeners for WSO2 projects.

Field Summary

protected org.apache.axis2.context.ConfigurationContext	configurationContext
protected int	port
protected int	proxyPort

Fields inherited from interface org.apache.axis2.transport.TransportListener

HOST_ADDRESS, PARAM_PORT

Constructor Summary

AbstractTransportListener()

Method Summary

void	destroy()
protected org.apache.axis2.addressing.EndpointReference	genEpr(String protocol, String ip, String serviceContextPath, String serviceName)
int	getActiveThreadCount()
double	getAvgSizeReceived()
double	getAvgSizeSent()
long	getBytesReceived()
long	getBytesSent()
org.apache.axis2.addressing.EndpointReference	getEPR(String protocol, String serviceName, String ip)
long	getFaultsReceiving()
long	getFaultsSending()
long	getLastResetTime()
long	getMaxSizeReceived()
long	getMaxSizeSent()
long	getMessagesReceived()
long	getMessagesSent()
long	getMetricsWindow()
long	getMinSizeReceived()
long	getMinSizeSent()
int	getQueueSize()
Map	getResponseCodeTable()
org.apache.axis2.context.SessionContext	getSessionContext(org.apache.axis2.context.MessageContext messageContext)
long	getTimeoutsReceiving()
long	getTimeoutsSending()
void	init(org.apache.axis2.context.ConfigurationContext configContext, org.apache.axis2.description.TransportInDescription transportIn)
void	maintenenceShutdown(long l)
void	pause()
void	resetStatistics()
void	resume()
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.axis2.transport.TransportListener

getEPRForService, getEPRsForService

Field Detail

configurationContext

protected org.apache.axis2.context.ConfigurationContext configurationContext

port

protected int port

proxyPort

protected int proxyPort

Constructor Detail

AbstractTransportListener

public AbstractTransportListener()

Method Detail

init

public void init(org.apache.axis2.context.ConfigurationContext configContext,
                 org.apache.axis2.description.TransportInDescription transportIn)
          throws org.apache.axis2.AxisFault

Specified by:

init in interface org.apache.axis2.transport.TransportListener

Throws:

org.apache.axis2.AxisFault

start

public void start()
           throws org.apache.axis2.AxisFault

Specified by:

start in interface org.apache.axis2.transport.TransportListener

Throws:

org.apache.axis2.AxisFault

stop

public void stop()
          throws org.apache.axis2.AxisFault

Specified by:

stop in interface org.apache.axis2.transport.TransportListener

Throws:

org.apache.axis2.AxisFault

getEPR

public org.apache.axis2.addressing.EndpointReference getEPR(String protocol,
                                                            String serviceName,
                                                            String ip)
                                                     throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

getSessionContext

public org.apache.axis2.context.SessionContext getSessionContext(org.apache.axis2.context.MessageContext messageContext)

Specified by:

getSessionContext in interface org.apache.axis2.transport.TransportListener

destroy

public void destroy()

Specified by:

destroy in interface org.apache.axis2.transport.TransportListener

genEpr

protected org.apache.axis2.addressing.EndpointReference genEpr(String protocol,
                                                               String ip,
                                                               String serviceContextPath,
                                                               String serviceName)
                                                        throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

pause

public void pause()
           throws org.apache.axis2.AxisFault

Specified by:

pause in interface org.apache.axis2.transport.base.ManagementSupport

Throws:

org.apache.axis2.AxisFault

resume

public void resume()
            throws org.apache.axis2.AxisFault

Specified by:

resume in interface org.apache.axis2.transport.base.ManagementSupport

Throws:

org.apache.axis2.AxisFault

maintenenceShutdown

public void maintenenceShutdown(long l)
                         throws org.apache.axis2.AxisFault

Specified by:

maintenenceShutdown in interface org.apache.axis2.transport.base.ManagementSupport

Throws:

org.apache.axis2.AxisFault

getActiveThreadCount

public int getActiveThreadCount()

Specified by:

getActiveThreadCount in interface org.apache.axis2.transport.base.ManagementSupport

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface org.apache.axis2.transport.base.ManagementSupport

getMessagesReceived

public long getMessagesReceived()

Specified by:

getMessagesReceived in interface org.apache.axis2.transport.base.ManagementSupport

getFaultsReceiving

public long getFaultsReceiving()

Specified by:

getFaultsReceiving in interface org.apache.axis2.transport.base.ManagementSupport

getBytesReceived

public long getBytesReceived()

Specified by:

getBytesReceived in interface org.apache.axis2.transport.base.ManagementSupport

getMessagesSent

public long getMessagesSent()

Specified by:

getMessagesSent in interface org.apache.axis2.transport.base.ManagementSupport

getFaultsSending

public long getFaultsSending()

Specified by:

getFaultsSending in interface org.apache.axis2.transport.base.ManagementSupport

getBytesSent

public long getBytesSent()

Specified by:

getBytesSent in interface org.apache.axis2.transport.base.ManagementSupport

getTimeoutsReceiving

public long getTimeoutsReceiving()

Specified by:

getTimeoutsReceiving in interface org.apache.axis2.transport.base.ManagementSupport

getTimeoutsSending

public long getTimeoutsSending()

Specified by:

getTimeoutsSending in interface org.apache.axis2.transport.base.ManagementSupport

getMinSizeReceived

public long getMinSizeReceived()

Specified by:

getMinSizeReceived in interface org.apache.axis2.transport.base.ManagementSupport

getMaxSizeReceived

public long getMaxSizeReceived()

Specified by:

getMaxSizeReceived in interface org.apache.axis2.transport.base.ManagementSupport

getAvgSizeReceived

public double getAvgSizeReceived()

Specified by:

getAvgSizeReceived in interface org.apache.axis2.transport.base.ManagementSupport

getMinSizeSent

public long getMinSizeSent()

Specified by:

getMinSizeSent in interface org.apache.axis2.transport.base.ManagementSupport

getMaxSizeSent

public long getMaxSizeSent()

Specified by:

getMaxSizeSent in interface org.apache.axis2.transport.base.ManagementSupport

getAvgSizeSent

public double getAvgSizeSent()

Specified by:

getAvgSizeSent in interface org.apache.axis2.transport.base.ManagementSupport

getResponseCodeTable

public Map getResponseCodeTable()

Specified by:

getResponseCodeTable in interface org.apache.axis2.transport.base.ManagementSupport

resetStatistics

public void resetStatistics()

Specified by:

resetStatistics in interface org.apache.axis2.transport.base.ManagementSupport

getLastResetTime

public long getLastResetTime()

Specified by:

getLastResetTime in interface org.apache.axis2.transport.base.ManagementSupport

getMetricsWindow

public long getMetricsWindow()

Specified by:

getMetricsWindow in interface org.apache.axis2.transport.base.ManagementSupport