Package eu.dnetlib.broker.utils

Class QueueManager

java.lang.Object

eu.dnetlib.broker.utils.QueueManager

@Component
public class QueueManager
extends Object

Constructor Summary

Constructors

Constructor	Description
QueueManager()

Method Summary

Modifier and Type	Method	Description
List<LbsQueue<?,?>>	getLbsQueues()
<K> LbsQueue<K,K>	newQueue(String name)
<T, K> LbsQueue<T,K>	newQueue(String name, Function<T,K> func, Predicate<K> predicate)
<K> LbsQueue<K,K>	newQueue(String name, Predicate<K> predicate)

Methods inherited from class java.lang.Object

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

Constructor Details

QueueManager

public QueueManager()

Method Details

newQueue

public <T,
K> LbsQueue<T,K> newQueue(String name,
 Function<T,K> func,
 Predicate<K> predicate)

newQueue

public <K> LbsQueue<K,K> newQueue(String name,
 Predicate<K> predicate)

newQueue

public <K> LbsQueue<K,K> newQueue(String name)

getLbsQueues

public List<LbsQueue<?,?>> getLbsQueues()