org.ak.trafficController.messaging.mem

Class InMemoryQueueTuner

java.lang.Object

org.ak.trafficController.messaging.mem.InMemoryQueueTuner

public class InMemoryQueueTuner
extends java.lang.Object

This class is responsible for tuning all configured dynamic queues. By tuning we mean that it will automatically add consumers, reduce consumers or clear queue as per user requirement. This class just facilitates DynamicSettings to actually tune.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	shouldContinue

Constructor Summary

Constructors

Constructor and Description
InMemoryQueueTuner(InMemoryQueueManager... managers) Constructor of InMemoryTuner which also registers managers which will be tuned.

Method Summary

Modifier and Type	Method and Description
java.lang.Long	getSleepInterval() Get configured sleep time.
InMemoryQueueTuner	setSleepInterval(java.lang.Long sleepInterval) Set sleep interval post which tuning will perform.
void	shutdown() Shutdown tuner.
void	startTuning() This method starts a tuning thread.
void	tune() Tuning process.
void	tune(DynamicSettings dynamicSettings) Tune a Dynamic setting.
void	tune(InMemoryQueueManager manager) Tune for a single manager.
protected void	tuneProcess() This is the actual method being called from the thread.

Methods inherited from class java.lang.Object

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

Field Detail

shouldContinue

protected boolean shouldContinue

Constructor Detail

InMemoryQueueTuner

public InMemoryQueueTuner(InMemoryQueueManager... managers)

Constructor of InMemoryTuner which also registers managers which will be tuned.

Parameters:

managers - Managers to be registered to tuner

Method Detail

startTuning

public void startTuning()

This method starts a tuning thread. The tuning thread tune all attached managers' queues.

tuneProcess

protected void tuneProcess()

This is the actual method being called from the thread.

tune

public void tune()

Tuning process. Tune all registered managers and settings.

tune

public void tune(InMemoryQueueManager manager)

Tune for a single manager.

Parameters:

manager - queue manager

tune

public void tune(DynamicSettings dynamicSettings)

Tune a Dynamic setting.

Parameters:

dynamicSettings - to be tuned

getSleepInterval

public java.lang.Long getSleepInterval()

Get configured sleep time.

Returns:

Sleep time after each tuning will perform

setSleepInterval

public InMemoryQueueTuner setSleepInterval(java.lang.Long sleepInterval)

Set sleep interval post which tuning will perform.

Parameters:

sleepInterval - Sleep interval to be set

Returns:

This tuner object to further use.

shutdown

public void shutdown()

Shutdown tuner.