Package org.apache.mina.management
Class StatCollector
java.lang.Object
org.apache.mina.management.StatCollector
Collects statistics of an
IoService
. It's polling all the sessions of a given
IoService. It's attaching a IoSessionStat
object to all the sessions polled
and filling the throughput values.
Usage :
IoService service = ... StatCollector collector = new StatCollector( service ); collector.start();By default the
StatCollector
is polling the sessions every 5 seconds. You can
give a different polling time using a second constructor.-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
The session attribute key forIoSessionStat
. -
Constructor Summary
ConstructorsConstructorDescriptionStatCollector
(IoService service) Create a stat collector for the given service with a default polling time of 5 seconds.StatCollector
(IoService service, int pollingInterval) create a stat collector for the given given service -
Method Summary
-
Field Details
-
KEY
The session attribute key forIoSessionStat
.
-
-
Constructor Details
-
StatCollector
Create a stat collector for the given service with a default polling time of 5 seconds.- Parameters:
service
- the IoService to inspect
-
StatCollector
create a stat collector for the given given service- Parameters:
service
- the IoService to inspectpollingInterval
- milliseconds
-
-
Method Details
-
start
public void start()Start collecting stats for theIoSession
of the service. New sessions or destroyed will be automaticly added or removed. -
stop
public void stop()Stop collecting stats. all theIoSessionStat
object will be removed of the polled session attachements. -
isRunning
public boolean isRunning()- Returns:
- true if started
-
getTotalProcessedSessions
public long getTotalProcessedSessions()total number of sessions processed by the stat collector- Returns:
- number of sessions
-
getBytesReadThroughput
public float getBytesReadThroughput() -
getBytesWrittenThroughput
public float getBytesWrittenThroughput() -
getMsgReadThroughput
public float getMsgReadThroughput() -
getMsgWrittenThroughput
public float getMsgWrittenThroughput() -
getSessionCount
public long getSessionCount()
-