org.ak.trafficController.messaging.mem

Class MultiplexInMemoryQueueManager

java.lang.Object

org.ak.trafficController.messaging.mem.MultiplexInMemoryQueueManager

public class MultiplexInMemoryQueueManager
extends java.lang.Object

This class is for having single set of consumers for all in memory queue. There can be a requirement where we want only one queue to be used and having all settings done for this queue. The consumers will be registered and based on the object, data will be picked.

Constructor Summary

Constructors

Constructor and Description
MultiplexInMemoryQueueManager() Constructor

Method Summary

Modifier and Type	Method and Description
<T> void	add(java.lang.String key, T item) Add item in the queue for given key.
<T> void	addMultiple(java.lang.String key, java.util.List<T> list) Add multiple items in the queue for given queue.
protected void	enqueMissedMuxIfAny(java.lang.String key) Enqueue all the missed items back to the queue.
protected <T> java.util.function.Consumer<MuxWrapper>	getConsumer(java.util.function.Consumer<T> consumer) Get the consumer of queue which will process the actual paased consumer.
protected void	init()
<T> void	register(java.lang.String key, java.util.function.Consumer<T> consumer) Register a consumer against a key.
DynamicSettings<MuxWrapper>	setDynamicSettings() Set dynamic nature for this queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplexInMemoryQueueManager

public MultiplexInMemoryQueueManager()

Constructor

Method Detail

init

protected void init()

register

public <T> void register(java.lang.String key,
                         java.util.function.Consumer<T> consumer)

Register a consumer against a key. All data having this key will be processed using this consmer.

Type Parameters:

T - type of consumer

Parameters:

key - Key of data

consumer - Consumer logic

enqueMissedMuxIfAny

protected void enqueMissedMuxIfAny(java.lang.String key)

Enqueue all the missed items back to the queue.

Parameters:

key - Key for which any missing items is processed

getConsumer

protected <T> java.util.function.Consumer<MuxWrapper> getConsumer(java.util.function.Consumer<T> consumer)

Get the consumer of queue which will process the actual paased consumer.

Type Parameters:

T - type of consumer

Parameters:

consumer - Actual consumer logic

Returns:

Consumer of queue

setDynamicSettings

public DynamicSettings<MuxWrapper> setDynamicSettings()

Set dynamic nature for this queue.

Returns:

Dynamic settings to further tune it

add

public <T> void add(java.lang.String key,
                    T item)

Add item in the queue for given key.

Type Parameters:

T - type of data

Parameters:

key - Key for which this data is designated

item - Item to be added

addMultiple

public <T> void addMultiple(java.lang.String key,
                            java.util.List<T> list)

Add multiple items in the queue for given queue. All items passed in collection will be added to the queue.

Type Parameters:

T - type of data

Parameters:

key - Key against which we want to add the data

list - Collection having data