org.apache.synapse.transport.nhttp.util

Class NhttpMetricsCollector

java.lang.Object

org.apache.axis2.transport.base.MetricsCollector

org.apache.synapse.transport.nhttp.util.NhttpMetricsCollector

public class NhttpMetricsCollector
extends org.apache.axis2.transport.base.MetricsCollector

This simple extension of the Axis2 transport MetricsCollector implementation, maintains a ConnectionsView instance, which is updated based on the events fired by the NHTTP transport implementation. In addition to the usual events handled by the Axis2 MetricsCollector, this implementation handles two new events:

• connected (this should get called whenever a new connection is created)
• disconnected (this should get called whenever an existing connection is closed)

These new events are used to update the ConnectionsView at runtime.

Field Summary

Fields inherited from class org.apache.axis2.transport.base.MetricsCollector

LEVEL_FULL, LEVEL_NONE, LEVEL_TRANSPORT

Constructor Summary

Constructors

Constructor and Description
NhttpMetricsCollector(boolean listener, String transportName)

Method Summary

Modifier and Type	Method and Description
void	connected()
void	destroy()
void	disconnected()
void	notifyReceivedMessageSize(long l)
void	notifySentMessageSize(long l)
void	setConnectionsPerHosts(Map<String,AtomicInteger> activeConnectionsPerHost)

Methods inherited from class org.apache.axis2.transport.base.MetricsCollector

getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getLevel, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMinSizeReceived, getMinSizeSent, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, incrementBytesReceived, incrementBytesReceived, incrementBytesSent, incrementBytesSent, incrementFaultsReceiving, incrementFaultsReceiving, incrementFaultsSending, incrementFaultsSending, incrementMessagesReceived, incrementMessagesReceived, incrementMessagesSent, incrementMessagesSent, incrementTimeoutsReceiving, incrementTimeoutsReceiving, incrementTimeoutsSending, incrementTimeoutsSending, notifyReceivedMessageSize, notifySentMessageSize, reportResponseCode, reportResponseCode, reset, setLevel

Methods inherited from class java.lang.Object

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

Constructor Detail

NhttpMetricsCollector

public NhttpMetricsCollector(boolean listener,
                             String transportName)

Method Detail

destroy

public void destroy()

connected

public void connected()

disconnected

public void disconnected()

notifyReceivedMessageSize

public void notifyReceivedMessageSize(long l)

Overrides:

notifyReceivedMessageSize in class org.apache.axis2.transport.base.MetricsCollector

notifySentMessageSize

public void notifySentMessageSize(long l)

Overrides:

notifySentMessageSize in class org.apache.axis2.transport.base.MetricsCollector

setConnectionsPerHosts

public void setConnectionsPerHosts(Map<String,AtomicInteger> activeConnectionsPerHost)