Package org.apache.mina.management

Class StatCollector

java.lang.Object
org.apache.mina.management.StatCollector
public class StatCollector extends Object
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 Details

  • Constructor Details

    • StatCollector

      public StatCollector(IoService service)
      Create a stat collector for the given service with a default polling time of 5 seconds.
      Parameters:
      service - the IoService to inspect

    • StatCollector

      public StatCollector(IoService service, int pollingInterval)
      create a stat collector for the given given service
      Parameters:
      service - the IoService to inspect
      pollingInterval - milliseconds

  • Method Details

    • start

      public void start()
      Start collecting stats for the IoSession of the service. New sessions or destroyed will be automaticly added or removed.

    • stop

      public void stop()
      Stop collecting stats. all the IoSessionStat object will be removed of the polled session attachements.

    • isRunning

      public boolean isRunning()
      is the stat collector started and polling the IoSession of the IoService
      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()