com.bigdata.journal

Class QueueStatsPlugIn

java.lang.Object

com.bigdata.journal.QueueStatsPlugIn

All Implemented Interfaces:

IPlugIn<Journal,ThreadPoolExecutorBaseStatisticsTask>

public class QueueStatsPlugIn
extends Object
implements IPlugIn<Journal,ThreadPoolExecutorBaseStatisticsTask>

Plugin for sampling the ExecutorService. This collects interesting statistics about the thread pool for reporting to the load balancer service.

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	QueueStatsPlugIn.Options Performance counters options.

Constructor Summary

Constructors

Constructor and Description
QueueStatsPlugIn()

Method Summary

Methods

Modifier and Type	Method and Description
ThreadPoolExecutorBaseStatisticsTask	getService() Return the service.
boolean	isRunning() Return true iff the service is running.
void	startService(Journal indexManager) Start the service.
void	stopService(boolean immediateShutdown) Stop the service.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueStatsPlugIn

public QueueStatsPlugIn()

Method Detail

startService

public void startService(Journal indexManager)

Start the service.

Setup sampling on the client's thread pool.

Specified by:

startService in interface IPlugIn<Journal,ThreadPoolExecutorBaseStatisticsTask>

stopService

public void stopService(boolean immediateShutdown)

Description copied from interface: IPlugIn

Stop the service.

Specified by:

stopService in interface IPlugIn<Journal,ThreadPoolExecutorBaseStatisticsTask>

Parameters:

immediateShutdown - true if the service should be stopped immediately.

getService

public ThreadPoolExecutorBaseStatisticsTask getService()

Description copied from interface: IPlugIn

Return the service.

Specified by:

getService in interface IPlugIn<Journal,ThreadPoolExecutorBaseStatisticsTask>

isRunning

public boolean isRunning()

Description copied from interface: IPlugIn

Return true iff the service is running.

Specified by:

isRunning in interface IPlugIn<Journal,ThreadPoolExecutorBaseStatisticsTask>