public class XmlRpcResourceManager extends Object
An XML RPC-based Resource manager.
Constructor and Description |
---|
XmlRpcResourceManager(int port) |
Modifier and Type | Method and Description |
---|---|
boolean |
addNode(Hashtable hashNode) |
boolean |
addNodeToQueue(String nodeId,
String queueName) |
boolean |
addQueue(String queueName) |
String |
getExecutionNode(String jobId) |
Hashtable |
getJobInfo(String jobId) |
int |
getJobQueueCapacity()
Gets the max number of Jobs allowed in JobQueue
|
int |
getJobQueueSize()
Gets the number of Jobs in JobQueue
|
Hashtable |
getNodeById(String nodeId) |
String |
getNodeLoad(String nodeId) |
List |
getNodes() |
List<String> |
getNodesInQueue(String queueName) |
List<String> |
getQueues() |
List<String> |
getQueuesWithNode(String nodeId) |
String |
handleJob(Hashtable jobHash,
boolean jobIn) |
boolean |
handleJob(Hashtable jobHash,
boolean jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
byte[] jobIn) |
boolean |
handleJob(Hashtable jobHash,
byte[] jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
Date jobIn) |
boolean |
handleJob(Hashtable jobHash,
Date jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
double jobIn) |
boolean |
handleJob(Hashtable jobHash,
double jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
Hashtable jobIn) |
boolean |
handleJob(Hashtable jobHash,
Hashtable jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
int jobIn) |
boolean |
handleJob(Hashtable jobHash,
int jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
String jobIn) |
boolean |
handleJob(Hashtable jobHash,
String jobIn,
String urlStr) |
String |
handleJob(Hashtable jobHash,
Vector jobIn) |
boolean |
handleJob(Hashtable jobHash,
Vector jobIn,
String urlStr) |
boolean |
isAlive() |
boolean |
isJobComplete(String jobId) |
boolean |
killJob(String jobId) |
static void |
main(String[] args) |
boolean |
removeNode(String nodeId) |
boolean |
removeNodeFromQueue(String nodeId,
String queueName) |
boolean |
removeQueue(String queueName) |
boolean |
setNodeCapacity(String nodeId,
int capacity) |
boolean |
shutdown() |
public boolean isAlive()
public int getJobQueueSize() throws JobRepositoryException
JobRepositoryException
- On Any Exceptionpublic int getJobQueueCapacity() throws JobRepositoryException
JobRepositoryException
- On Any Exceptionpublic boolean isJobComplete(String jobId) throws JobRepositoryException
JobRepositoryException
public Hashtable getJobInfo(String jobId) throws JobRepositoryException
JobRepositoryException
public String handleJob(Hashtable jobHash, Hashtable jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, int jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, boolean jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, String jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, double jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, Date jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, Vector jobIn) throws SchedulerException
SchedulerException
public String handleJob(Hashtable jobHash, byte[] jobIn) throws SchedulerException
SchedulerException
public boolean handleJob(Hashtable jobHash, Hashtable jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, int jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, boolean jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, String jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, double jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, Date jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, Vector jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public boolean handleJob(Hashtable jobHash, byte[] jobIn, String urlStr) throws JobExecutionException
JobExecutionException
public List getNodes() throws MonitorException
MonitorException
public Hashtable getNodeById(String nodeId) throws MonitorException
MonitorException
public boolean killJob(String jobId) throws MonitorException
MonitorException
public List<String> getQueues() throws QueueManagerException
QueueManagerException
public boolean addQueue(String queueName) throws QueueManagerException
QueueManagerException
public boolean removeQueue(String queueName) throws QueueManagerException
QueueManagerException
public boolean addNode(Hashtable hashNode) throws MonitorException
MonitorException
public boolean removeNode(String nodeId) throws MonitorException
MonitorException
public boolean addNodeToQueue(String nodeId, String queueName) throws QueueManagerException
QueueManagerException
public boolean removeNodeFromQueue(String nodeId, String queueName) throws QueueManagerException
QueueManagerException
public List<String> getNodesInQueue(String queueName) throws QueueManagerException
QueueManagerException
public List<String> getQueuesWithNode(String nodeId) throws QueueManagerException
QueueManagerException
public boolean shutdown()
public String getNodeLoad(String nodeId) throws MonitorException
MonitorException
public boolean setNodeCapacity(String nodeId, int capacity)
Copyright © 1999-2015 Apache OODT. All Rights Reserved.