public class QueueManager extends Object
The Queue to Node Mapping Manager
| Modifier and Type | Field and Description | 
|---|---|
| protected Map<String,LinkedHashSet<String>> | queueToNodesMapping | 
| Constructor and Description | 
|---|
| QueueManager() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | addNodeToQueue(String nodeId,
              String queueName) | 
| void | addQueue(String queueName) | 
| boolean | containsQueue(String queueName) | 
| List<String> | getNodes(String queueName) | 
| List<String> | getQueues() | 
| Vector<String> | getQueues(String nodeId) | 
| void | removeNodeFromQueue(String nodeId,
                   String queueName) | 
| void | removeQueue(String queueName) | 
protected Map<String,LinkedHashSet<String>> queueToNodesMapping
public boolean containsQueue(String queueName)
public void addNodeToQueue(String nodeId, String queueName) throws QueueManagerException
QueueManagerExceptionpublic void addQueue(String queueName)
public List<String> getNodes(String queueName) throws QueueManagerException
QueueManagerExceptionpublic void removeNodeFromQueue(String nodeId, String queueName) throws QueueManagerException
QueueManagerExceptionpublic void removeQueue(String queueName)
Copyright © 1999–2017 Apache OODT. All rights reserved.