Index (in-memory-queue 2.1.0 API)

A B C D E G H I M N O P Q R S T U W

A

add(T) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method add an item to the queue.
add(Collection<T>) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method adds list of items to be processed in queue.
add(T) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Add item to the queue.
add(String, T) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Add message to the queue.
add(String, T) - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Add item in the queue for given key.
addAllFromCollection(Collection<T>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method adds data present in input collection
addAndCreate(String, T) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Add message.
addAndRegisterIfRequired(String, T) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Adds an item in queue.
addAndRegisterIfRequiredForCollection(String, Collection<T>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Adds all items in collection to queue.
addBatchListener(String, Consumer<List<T>>, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Add batch listener to queue having passed name
addDynamicSetting(DynamicSettings) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Add dynamic setting to start tuning of the same.
addItemInQueue(T) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: This method is responsible of adding data in queue.
addItems(String, Collection<T>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Add messages to the queue.
addItemsInQueue(Collection<T>) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: This method is responsible of adding data in list in queue.
addListener(String, Consumer<T>, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Add listener to queue having passed name.
addManager(InMemoryQueueManager) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Add in memory queue manager to start tuning of the same.
addMultiple(String, List<T>) - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Add multiple items in the queue for given queue.
addPreCleanHandler(Consumer<Queue<T>>) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Add pre clean handler.
addStillAllowed() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: This method tells if we can still add in the queue.
adjust() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: This method handles the increase/decrease of consumers.

B

batchProcess(Consumer<List<T>>, String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method gets from the queue and process.
buildErrorMessage(String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Build error message using consumer name and queue name.

C

clear(Consumer<Queue<T>>...) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method clears the current queue and pass the data to the consumer.
clear(Consumer<Queue<T>>...) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method clears the queue.

D

decreaseConsumerIfPossible() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Decrease consumer if low limit attained back and we still have more consumers than minimum consumers.
decrementBatchConsumer() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Decrement batch consumer count.
decrementDirectConsumer() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Decrement direct consumer count.
doNotify() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method Notify all consumers.
DynamicSettings<T> - Class in org.ak.trafficController.messaging.mem: This class handles dynamic settings of flow of messages.
DynamicSettings() - Constructor for class org.ak.trafficController.messaging.mem.DynamicSettings
dynamicSettings - Variable in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Dynamic setting registered to this manager.

E

enqueMissedMuxIfAny(String) - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Enqueue all the missed items back to the queue.

G

GenericInMemoryQueue<T> - Class in org.ak.trafficController.messaging.mem: Each object of this class act as in memory queue.
GenericInMemoryQueue(String) - Constructor for class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Constructor of Generic in memory queue.
GenericInMemoryQueue(String, int) - Constructor for class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Constructor which also configures batch size which is used by batch consumers.
getBatchConsumerCount() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Get batch consumer count.
getBatchConsumerCount() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Get current batch consumer count
getBatchConsumerCount(String) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Get number of batch consumers currently attached to queue.
getBatchConsumerName(Integer) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Name of batch consumer.
getBatchData() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Get batch data which will be used to pass to batch consumer.
getBatchSize() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Batch size which will be used by batch consumers.
getCleaners() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Get registered cleaners.
getConsumer(Consumer<T>) - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Get the consumer of queue which will process the actual paased consumer.
getDirectConsumerCount() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Get number of direct consumers.
getDirectConsumerCount() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Get direct consumer count.
getDirectConsumerCount(String) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Get number of consumers currently attached to queue.
getDirectConsumerName(Integer) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Name of direct consumer.
getExceptionMessage(String, T) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method prepares the exception message containing name of consumer and queue.
getExceptionMessage(String, List<T>) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method builds the exception message for batch consumer.
getHighLimitWhenToIncreaseConsumer() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Get high limit when increase of consumer is tried.
getKey() - Method in class org.ak.trafficController.messaging.mem.wrapper.MuxWrapper: Get key against which this message will be processed.
getLowLimitWhenToDecreseConsumer() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Get low limit when decrease of consumer is tried.
getMaxBatchConsumer() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Maximum batch consumers which can be created.
getMaxDirectConsumer() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Maximum direct consumers which can be created.
getMinBatchConsumer() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Minimum batch consumers which can be reduced to.
getMinDirectConsumer() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Minimum direct consumers which can be reduced to.
getNumberOfItemsInQueue() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Get number of items in queue.
getNumberOfItemsInQueue() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Get current number of items in queue.
getNumberOfRetriesToWait() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Number of retries while adding at threshold.
getObj() - Method in class org.ak.trafficController.messaging.mem.wrapper.MuxWrapper: Get data to be consumed by actual consumer.
getQueue() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings
getQueueName() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Get queue name.
getShouldClearQueueAtThreshold() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Should clear the queue if threshold reached.
getShouldRetrySenderTillThresholdNotRecovered() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Is retry enabled while adding if threshold is reached.
getShouldStopAddingAtThreshold() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Should stop adding at threshold.
getShouldThrowExceptionPostRetry() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Should throw exception post retries.
getShouldThrowExceptionWhenThresholdAtAdd() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Should throw exception when threshold reached in add process.
getSleepInterval() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Get configured sleep time.
getSleepPostConsumingAll() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue
getSleepPostConsumingEvery() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue
getSleepTimePostConsumingAllMessage() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue
getSleepTimePostEachConsumption() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue
getThresholdWhenNoMoreItemsShouldBeHandled() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Threshold when more item should not be added.
getWaitForRetryThresholdLimit() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Wait time for retries.
getWaitTimeout() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This is the wait time for which different consumers wait for some message.

H

handleStopAddingAtThreshold() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: This method is to handle in situation where we need to continue even when threshold reached.

I

increaseConsumerIfPossible() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Increase consumers if high limit is reached and we still have number of consumers less than total current consumers.
incrementBatchConsumer() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Increment batch consumer count.
incrementDirectConsumer() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Increment direct consumer count.
init() - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager
initialize(String, Consumer<T>, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Initialize a queue with passed name, consumer and number of consumers.
initializeForBatch(String, Consumer<List<T>>, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Initialize a queue with passed name, consumer and number of consumers.
InMemoryQueue<T> - Class in org.ak.trafficController.messaging.mem: This class can be considered as extension of GenericInMemoryQueue.
InMemoryQueue(String) - Constructor for class org.ak.trafficController.messaging.mem.InMemoryQueue: Creates a new in memory queue.
InMemoryQueueManager - Class in org.ak.trafficController.messaging.mem: This queue manager creates multiple in memory queue.
InMemoryQueueManager() - Constructor for class org.ak.trafficController.messaging.mem.InMemoryQueueManager
InMemoryQueueTuner - Class in org.ak.trafficController.messaging.mem: This class is responsible for tuning all configured dynamic queues.
InMemoryQueueTuner(InMemoryQueueManager...) - Constructor for class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Constructor of InMemoryTuner which also registers managers which will be tuned.
isBatchConsumerSet() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method lets us know that for this queue, any batch consumer set.
isDirectConsumerSet() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method lets us know that for this queue, any direct consumer set.
isHasShutdown() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Have this queue shutdown?
isShouldSleepAfterEveryConsumption() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue
isShouldSleepConsumingAll() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue

M

MultiplexInMemoryQueueManager - Class in org.ak.trafficController.messaging.mem: This class is for having single set of consumers for all in memory queue.
MultiplexInMemoryQueueManager() - Constructor for class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Constructor
MuxWrapper - Class in org.ak.trafficController.messaging.mem.wrapper: This class wraps the actual object.
MuxWrapper() - Constructor for class org.ak.trafficController.messaging.mem.wrapper.MuxWrapper

N

notifyConsumers() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method notify on addition of an item in the queue.

O

org.ak.trafficController.messaging.exception - package org.ak.trafficController.messaging.exception
org.ak.trafficController.messaging.mem - package org.ak.trafficController.messaging.mem
org.ak.trafficController.messaging.mem.wrapper - package org.ak.trafficController.messaging.mem.wrapper

P

processAddItem(Consumer<K>, K) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Checks if add item allowed and add the item to queue.
processForCounter(int, int, Consumer<Integer>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Process for add/remove a consumer from given start to given end index.

Q

queues - Variable in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Queues mapping to this manager.

R

register(Consumer<T>, String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method register the direct consumer.
register(String, Consumer<T>) - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Register a consumer against a key.
registerBatchConsumer(Consumer<List<T>>, String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Register batch consumer
registerQueueIfAbsent(String) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: This makes sure only one queue is created for a given name.
removeAllBatchConsumers() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Remove all batch consumers.
removeAllDirectConsumers() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Removes all direct consumers.
removeBatchConsumer() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Remove Batch Consumer.
removeDirectConsumer() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Remove direct consumer.
resetConsumer(Consumer<Integer>, Consumer<Integer>, int, AtomicInteger) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Whenever a consumer needs to be changed, this method is called to remove current consumers of queue and then add fresh consumers.

S

setBatchConsumer(Consumer<List<T>>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Set batch consumer logic
setBatchConsumerCount(int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Reset batch consumer count.
setBatchConsumerCount(String, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Set number of batch consumers of queue having passed name.
setBatchConsumers(Consumer<List<T>>, int, InMemoryQueue<T>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Set batch consumers in a given queue.
setBatchSize(int) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Setter Batch size which will be used by batch consumers.
setBatchSize(int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Set batch size of the queue.
setBatchSize(String, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: This method sets the batch size which will be used by batch consumer for given queue having passed queue name.
setConsumerCount(int, int, Consumer<Integer>, Consumer<Integer>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method is responsible for increasing/decreasing consumer count.
setConsumerCount(String, int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Set Number of direct consumers of queue having passed name.
setConsumers(Consumer<T>, int, InMemoryQueue<T>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Set consumers in a given queue.
setDirectConsumer(Consumer<T>) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Set direct consumer which will work on the data present in queue.
setDirectConsumerCount(int) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Set direct consumer count.
setDynamic(String) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: This method makes queue dynamic.
setDynamicSettings() - Method in class org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager: Set dynamic nature for this queue.
setHighLimitWhenToIncreaseConsumer(Long) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Set high limit when increase of consumer is tried.
setKey(String) - Method in class org.ak.trafficController.messaging.mem.wrapper.MuxWrapper: Set the key against which this data will be processed.
setLowLimitWhenToDecreseConsumer(Long) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Set low limit when decrease of consumer is tried.
setMaxBatchConsumer(Integer) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Set the number of maximum batch consumers which can be created.
setMaxDirectConsumer(Integer) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Set the number of maximum direct consumers which can be created.
setMinBatchConsumer(Integer) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setter of minimum batch consumers till which consumers count be reduced to.
setMinDirectConsumer(Integer) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setter of mimimum direct consumers till which consumers count be reduced to.
setNumberOfItemsInQueue(AtomicLong) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Set number of items in queue.
setNumberOfRetriesToWait(Long) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setter of Number of retries while adding at threshold.
setObj(Object) - Method in class org.ak.trafficController.messaging.mem.wrapper.MuxWrapper: Set the data in the message.
setQueue(InMemoryQueue<T>) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setting queue to be worked upon.
setQueueName(String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Set name of the queue
setShouldClearQueueAtThreshold(Boolean) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Configures to if should clear queue at threshold.
setShouldRetrySenderTillThresholdNotRecovered(Boolean) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setter of retry enabled while adding if threshold is reached.
setShouldStopAddingAtThreshold(Boolean) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setter of should stop adding at threshold.
setShouldThrowExceptionPostRetry(Boolean) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Set if exception should be thrown to producers if threshold is reached and configured amount of retries are also taken.
setShouldThrowExceptionWhenThresholdAtAdd(Boolean) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Setter of Should throw exception when threshold reached in add process.
setSleepInterval(Long) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Set sleep interval post which tuning will perform.
setSleepPostConsumingAll(Long) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method sets sleepPostConsumingAll with the value passed.
setSleepPostConsumingEach(Long) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method sets sleepPostConsumingEvery with the value passed.
setSleepTimePostConsumingAllMessage(Long) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method sets sleepTimePostConsumingAllMessage with the value passed.
setSleepTimePostEachConsumption(Long) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: This method sets sleepTimePostEachConsumption with the value passed.
setThresholdWhenNoMoreItemsShouldBeHandled(Long) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Threshold when more item should not be added.
setWaitForRetryThresholdLimit(Long) - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Set wait time for retry.
setWaitTimeout(int) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This is the wait time for which different consumers wait for some message.
shouldContinue - Variable in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner
shutdown() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: Shutdown underlying queue.
shutdown() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: To cleanup, shutdown method should be called.
shutdown() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueue: Shutdown the queue.
shutdown() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueManager: Shutdown all queues and dynamic settings.
shutdown() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Shutdown tuner.
singleItemProcess(Consumer<T>, String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method polls from the queue and process the consumer with data found.
sleep(Long) - Static method in class org.ak.trafficController.messaging.mem.DynamicSettings: Sleep for configured amount.
sleepIfConfigured() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: Sleep post consuming all messages if configured.
sleepIfConfiguredPostEveryConsumption() - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue
startConsumer(Runnable, String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method starts the consumer.
startListening(Runnable, String, Collection<String>) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method start listener.
startTuning() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: This method starts a tuning thread.

T

ThresholdReachedException - Exception in org.ak.trafficController.messaging.exception: Threshold reached exception.
ThresholdReachedException() - Constructor for exception org.ak.trafficController.messaging.exception.ThresholdReachedException: Constructor of Threshold reached exception.
ThresholdReachedException(String) - Constructor for exception org.ak.trafficController.messaging.exception.ThresholdReachedException: Constructor of threshold reached exception.
tryIfCanFreeUp() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: It verifies if it can free up messages based on configurations and condition.
tune() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Tuning process.
tune(InMemoryQueueManager) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Tune for a single manager.
tune(DynamicSettings) - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: Tune a Dynamic setting.
tuneProcess() - Method in class org.ak.trafficController.messaging.mem.InMemoryQueueTuner: This is the actual method being called from the thread.

U

unregister(String) - Method in class org.ak.trafficController.messaging.mem.GenericInMemoryQueue: This method unregister the consumer.

W

waitForRetriesIfAny() - Method in class org.ak.trafficController.messaging.mem.DynamicSettings: This method waits for configured number and for given time if allowed to wait.

A B C D E G H I M N O P Q R S T U W