java.lang.Object
  org.apache.oodt.cas.resource.system.XmlRpcResourceManagerClient

public class XmlRpcResourceManagerClient

extends Object

Version:

$Revision$

The XML RPC based resource manager client.

Author:

mattmann

public XmlRpcResourceManagerClient(URL url)

Constructs a new XmlRpcResourceManagerClient with the given url.

Parameters:

url - The url pointer to the xml rpc resource manager service.

public static void main(String[] args)

public boolean isJobComplete(String jobId)
                      throws JobRepositoryException

Throws:

JobRepositoryException

public Job getJobInfo(String jobId)
               throws JobRepositoryException

Throws:

JobRepositoryException

public boolean isAlive()

public int getJobQueueSize()
                    throws JobRepositoryException

Gets the number of Jobs in JobQueue

Returns:

Number of Jobs in JobQueue

Throws:

JobRepositoryException - On Any Exception

public int getJobQueueCapacity()
                        throws JobRepositoryException

Gets the max number of Jobs allowed in JobQueue

Returns:

Max number of Jobs

Throws:

JobRepositoryException - On Any Exception

public boolean killJob(String jobId)

public String getExecutionNode(String jobId)

public String submitJob(Job exec,
                        JobInput in)
                 throws JobExecutionException

Throws:

JobExecutionException

public boolean submitJob(Job exec,
                         JobInput in,
                         URL hostUrl)
                  throws JobExecutionException

Throws:

JobExecutionException

public List getNodes()
              throws MonitorException

Throws:

MonitorException

public ResourceNode getNodeById(String nodeId)
                         throws MonitorException

Throws:

MonitorException

public URL getResMgrUrl()

Returns:

the resMgrUrl

public void setResMgrUrl(URL resMgrUrl)

Parameters:

resMgrUrl - the resMgrUrl to set

public void addQueue(String queueName)
              throws QueueManagerException

Creates a queue with the given name

Parameters:

queueName - The name of the queue to be created

Throws:

QueueManagerException - on any error

public void removeQueue(String queueName)
                 throws QueueManagerException

Removes the queue with the given name

Parameters:

queueName - The name of the queue to be removed

Throws:

QueueManagerException - on any error

public void addNode(ResourceNode node)
             throws MonitorException

Adds a node

Parameters:

node - The node to be added

Throws:

MonitorException - on any error

public void removeNode(String nodeId)
                throws MonitorException

Removes the node with the given id

Parameters:

nodeId - The id of the node to be removed

Throws:

MonitorException - on any error

public void setNodeCapacity(String nodeId,
                            int capacity)
                     throws MonitorException

Throws:

MonitorException

public void addNodeToQueue(String nodeId,
                           String queueName)
                    throws QueueManagerException

Addes the node with given id to the queue with the given name

Parameters:

nodeId - The id of the node to be added to the given queueName

queueName - The name of the queue to add the given node

Throws:

QueueManagerException - on any error

public void removeNodeFromQueue(String nodeId,
                                String queueName)
                         throws QueueManagerException

Remove the node with the given id from the queue with the given name

Parameters:

nodeId - The id of the node to be remove from the given queueName

queueName - The name of the queue from which to remove the given node

Throws:

QueueManagerException - on any error

public List<String> getQueues()
                       throws QueueManagerException

Gets a list of currently supported queue names

Returns:

A list of currently supported queue names

Throws:

QueueManagerException - on any error

public List<String> getNodesInQueue(String queueName)
                             throws QueueManagerException

Gets a list of ids of the nodes in the given queue

Parameters:

queueName - The name of the queue to get node ids from

Returns:

List of node ids in the given queueName

Throws:

QueueManagerException - on any error

public List<String> getQueuesWithNode(String nodeId)
                               throws QueueManagerException

Gets a list of queues which contain the node with the given nodeId

Parameters:

nodeId - The id of the node to get queues it belongs to

Returns:

List of queues which contain the give node

Throws:

QueueManagerException - on any error

public String getNodeLoad(String nodeId)
                   throws MonitorException

Report on the load of the requested node

Parameters:

nodeId - The id of the node to be polled

Returns:

A String showing a fraction of the loads node over its capacity

Throws:

MonitorException - on any error