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() |
List<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) throws QueueManagerException
QueueManagerException
public List<String> getNodes(String queueName) throws QueueManagerException
QueueManagerException
public List<String> getQueues() throws QueueManagerException
QueueManagerException
public List<String> getQueues(String nodeId) throws QueueManagerException
QueueManagerException
public void removeNodeFromQueue(String nodeId, String queueName) throws QueueManagerException
QueueManagerException
public void removeQueue(String queueName) throws QueueManagerException
QueueManagerException
Copyright © 1999-2014 Apache OODT. All Rights Reserved.