org.ak.trafficController.messaging.mem

Class InMemoryQueueManager

java.lang.Object

org.ak.trafficController.messaging.mem.InMemoryQueueManager

public class InMemoryQueueManager
extends java.lang.Object

This queue manager creates multiple in memory queue. This helps user to directly create queue, add listeners, add data without taking any reference.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<java.lang.String,DynamicSettings>	dynamicSettings Dynamic setting registered to this manager.
protected java.util.Map<java.lang.String,InMemoryQueue>	queues Queues mapping to this manager.

Constructor Summary

Constructors

Constructor and Description
InMemoryQueueManager()

Method Summary

Modifier and Type	Method and Description
<T> boolean	add(java.lang.String queueName, T item) Add message to the queue.
<T> void	addAndCreate(java.lang.String queueName, T item) Add message.
<T> boolean	addAndRegisterIfRequired(java.lang.String queueName, T item) Adds an item in queue.
<T> boolean	addAndRegisterIfRequiredForCollection(java.lang.String queueName, java.util.Collection<T> item) Adds all items in collection to queue.
<T> void	addBatchListener(java.lang.String queueName, java.util.function.Consumer<java.util.List<T>> consumer, int numberOfConsumers) Add batch listener to queue having passed name
<T> boolean	addItems(java.lang.String queueName, java.util.Collection<T> items) Add messages to the queue.
<T> void	addListener(java.lang.String queueName, java.util.function.Consumer<T> consumer, int numberOfConsumers) Add listener to queue having passed name.
java.lang.Integer	getBatchConsumerCount(java.lang.String queueName) Get number of batch consumers currently attached to queue.
java.lang.Integer	getDirectConsumerCount(java.lang.String queueName) Get number of consumers currently attached to queue.
<T> void	initialize(java.lang.String queueName, java.util.function.Consumer<T> consumer, int numberOfConsumers) Initialize a queue with passed name, consumer and number of consumers.
<T> void	initializeForBatch(java.lang.String queueName, java.util.function.Consumer<java.util.List<T>> consumer, int numberOfConsumers) Initialize a queue with passed name, consumer and number of consumers.
protected <T> InMemoryQueue<T>	registerQueueIfAbsent(java.lang.String queueName) This makes sure only one queue is created for a given name.
void	setBatchConsumerCount(java.lang.String queueName, int batchConsumerCount) Set number of batch consumers of queue having passed name.
protected <T> void	setBatchConsumers(java.util.function.Consumer<java.util.List<T>> consumer, int numberOfConsumers, InMemoryQueue<T> queue) Set batch consumers in a given queue.
void	setBatchSize(java.lang.String queueName, int batchSize) This method sets the batch size which will be used by batch consumer for given queue having passed queue name.
void	setConsumerCount(java.lang.String queueName, int consumerCount) Set Number of direct consumers of queue having passed name.
protected <T> void	setConsumers(java.util.function.Consumer<T> consumer, int numberOfConsumers, InMemoryQueue<T> queue) Set consumers in a given queue.
<T> DynamicSettings<T>	setDynamic(java.lang.String queueName) This method makes queue dynamic.
void	shutdown() Shutdown all queues and dynamic settings.

Methods inherited from class java.lang.Object

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

Field Detail

queues

protected java.util.Map<java.lang.String,InMemoryQueue> queues

Queues mapping to this manager.

dynamicSettings

protected java.util.Map<java.lang.String,DynamicSettings> dynamicSettings

Dynamic setting registered to this manager.

Constructor Detail

InMemoryQueueManager

public InMemoryQueueManager()

Method Detail

initialize

public <T> void initialize(java.lang.String queueName,
                           java.util.function.Consumer<T> consumer,
                           int numberOfConsumers)

Initialize a queue with passed name, consumer and number of consumers. The consumer passed is treated as direct consumer.

Type Parameters:

T - type of consumer

Parameters:

queueName - Name of queue

consumer - Consumer logic

numberOfConsumers - Number of consumers

setBatchSize

public void setBatchSize(java.lang.String queueName,
                         int batchSize)

This method sets the batch size which will be used by batch consumer for given queue having passed queue name.

Parameters:

queueName - Queue name

batchSize - batch size

initializeForBatch

public <T> void initializeForBatch(java.lang.String queueName,
                                   java.util.function.Consumer<java.util.List<T>> consumer,
                                   int numberOfConsumers)

Initialize a queue with passed name, consumer and number of consumers. The consumer passed is treated as batch consumer.

Type Parameters:

T - type of consumer

Parameters:

queueName - Name of queue

consumer - Consumer logic

numberOfConsumers - Number of consumers

registerQueueIfAbsent

protected <T> InMemoryQueue<T> registerQueueIfAbsent(java.lang.String queueName)

This makes sure only one queue is created for a given name.

Type Parameters:

T - type of queue required

Parameters:

queueName - Name of the queue

Returns:

Queue for the given queue

setConsumers

protected <T> void setConsumers(java.util.function.Consumer<T> consumer,
                                int numberOfConsumers,
                                InMemoryQueue<T> queue)

Set consumers in a given queue. If already attached consumers is less than required, this method register more. Else, this method unregister consumers.

Type Parameters:

T - type of queue required

Parameters:

consumer - Consumer of the queue which is looking for working on data present in queue.

numberOfConsumers - number of consumers required for queue to

queue - Queue on which we are looking for setting consumers.

setBatchConsumers

protected <T> void setBatchConsumers(java.util.function.Consumer<java.util.List<T>> consumer,
                                     int numberOfConsumers,
                                     InMemoryQueue<T> queue)

Set batch consumers in a given queue. Batch consumers work on batch of data instead of individual records. If already attached consumers is less than required, this method register more. Else, this method unregister consumers.

Type Parameters:

T - type of queue required

Parameters:

consumer - Consumer of the queue which is looking for working on data present in queue.

numberOfConsumers - number of consumers required for queue to

queue - Queue on which we are looking for setting consumers.

addAndRegisterIfRequired

public <T> boolean addAndRegisterIfRequired(java.lang.String queueName,
                                            T item)

Adds an item in queue. If queue is not created till now, this method also creates one.

Type Parameters:

T - type of queue required

Parameters:

queueName - Name of queue

item - Item to be added

Returns:

true if successfully adds item in queue

addAndRegisterIfRequiredForCollection

public <T> boolean addAndRegisterIfRequiredForCollection(java.lang.String queueName,
                                                         java.util.Collection<T> item)

Adds all items in collection to queue. If queue is not created till now, this method also creates one.

Type Parameters:

T - type of queue required

Parameters:

queueName - Name of queue

item - Collection

Returns:

true if successfully adds in queue

add

public <T> boolean add(java.lang.String queueName,
                       T item)

Add message to the queue.

Type Parameters:

T - type of queue

Parameters:

queueName - name of queue

item - Item to be added

Returns:

true if successfully adds item to queue

addItems

public <T> boolean addItems(java.lang.String queueName,
                            java.util.Collection<T> items)

Add messages to the queue.

Type Parameters:

T - type of queue

Parameters:

queueName - Name of queue

items - Items to be added

Returns:

true if successfully added

addListener

public <T> void addListener(java.lang.String queueName,
                            java.util.function.Consumer<T> consumer,
                            int numberOfConsumers)

Add listener to queue having passed name.

Type Parameters:

T - type of queue

Parameters:

queueName - Name of queue

consumer - Consumer logic

numberOfConsumers - Number of consumers

addBatchListener

public <T> void addBatchListener(java.lang.String queueName,
                                 java.util.function.Consumer<java.util.List<T>> consumer,
                                 int numberOfConsumers)

Add batch listener to queue having passed name

Type Parameters:

T - type of queue

Parameters:

queueName - Name of queue

consumer - Consumer logic

numberOfConsumers - Number of consumers

addAndCreate

public <T> void addAndCreate(java.lang.String queueName,
                             T item)

Add message. If required create queue with no data. WARN - This should be used with thorough analysis as in case you passed wrong name for adding, it will create extra queue.

Type Parameters:

T - type of queue

Parameters:

queueName - Name of queue

item - Data to be added

getDirectConsumerCount

public java.lang.Integer getDirectConsumerCount(java.lang.String queueName)

Get number of consumers currently attached to queue.

Parameters:

queueName - Name of queue for which consumers count is required

Returns:

Number of consumers

getBatchConsumerCount

public java.lang.Integer getBatchConsumerCount(java.lang.String queueName)

Get number of batch consumers currently attached to queue.

Parameters:

queueName - Name of queue for which consumers count is required

Returns:

Number of consumers

setConsumerCount

public void setConsumerCount(java.lang.String queueName,
                             int consumerCount)

Set Number of direct consumers of queue having passed name.

Parameters:

queueName - Name of queue

consumerCount - Consumer count

setBatchConsumerCount

public void setBatchConsumerCount(java.lang.String queueName,
                                  int batchConsumerCount)

Set number of batch consumers of queue having passed name.

Parameters:

queueName - Name of queue

batchConsumerCount - Batch consumer count to be set

setDynamic

public <T> DynamicSettings<T> setDynamic(java.lang.String queueName)

This method makes queue dynamic. By dynamic it means that number of consumer will increase and reduce on basis of load. This method returns DynamicSettings by which one can configure particular queue behavior.

Type Parameters:

T - type of queue.

Parameters:

queueName - Queue Name

Returns:

Dynamic settings

shutdown

public void shutdown()

Shutdown all queues and dynamic settings.