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()