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
QueueManagerException
public void addQueue(String queueName)
public List<String> getNodes(String queueName) throws QueueManagerException
QueueManagerException
public void removeNodeFromQueue(String nodeId, String queueName) throws QueueManagerException
QueueManagerException
public void removeQueue(String queueName)
Copyright © 1999–2017 Apache OODT. All rights reserved.