com.xxdb.streaming.client

Class QueueManager

java.lang.Object

com.xxdb.streaming.client.QueueManager

public class QueueManager
extends Object

Constructor Summary

Constructors

Constructor and Description
QueueManager()

Method Summary

Modifier and Type	Method and Description
BlockingQueue<List<IMessage>>	addQueue(String topic)
void	changeQueue(String topic, BlockingQueue<List<IMessage>> q)
List<String>	getAllTopic()
BlockingQueue<List<IMessage>>	getQueue(String topic)
void	removeQueue(String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueManager

public QueueManager()

Method Detail

addQueue

public BlockingQueue<List<IMessage>> addQueue(String topic)

changeQueue

public void changeQueue(String topic,
                        BlockingQueue<List<IMessage>> q)

getQueue

public BlockingQueue<List<IMessage>> getQueue(String topic)

getAllTopic

public List<String> getAllTopic()

removeQueue

public void removeQueue(String topic)