Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.apache.oodt.cas.resource.system
Class XmlRpcResourceManager

java.lang.Object
  extended by org.apache.oodt.cas.resource.system.XmlRpcResourceManager

public class XmlRpcResourceManager
extends Object

Version:
$Revision$

An XML RPC-based Resource manager.

Author:
woollard

Constructor Summary
XmlRpcResourceManager(int port)
           
 
Method Summary
 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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

XmlRpcResourceManager

public XmlRpcResourceManager(int port)
                      throws Exception
Throws:
Exception
Method Detail

isAlive

public boolean isAlive()

getJobQueueSize

public int getJobQueueSize()
                    throws JobRepositoryException
Gets the number of Jobs in JobQueue

Returns:
Number of Jobs in JobQueue
Throws:
JobRepositoryException - On Any Exception

getJobQueueCapacity

public int getJobQueueCapacity()
                        throws JobRepositoryException
Gets the max number of Jobs allowed in JobQueue

Returns:
Max number of Jobs
Throws:
JobRepositoryException - On Any Exception

isJobComplete

public boolean isJobComplete(String jobId)
                      throws JobRepositoryException
Throws:
JobRepositoryException

getJobInfo

public Hashtable getJobInfo(String jobId)
                     throws JobRepositoryException
Throws:
JobRepositoryException

handleJob

public String handleJob(Hashtable jobHash,
                        Hashtable jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        int jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        boolean jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        String jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        double jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        Date jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        Vector jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public String handleJob(Hashtable jobHash,
                        byte[] jobIn)
                 throws SchedulerException
Throws:
SchedulerException

handleJob

public boolean handleJob(Hashtable jobHash,
                         Hashtable jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         int jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         boolean jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         String jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         double jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         Date jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         Vector jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

handleJob

public boolean handleJob(Hashtable jobHash,
                         byte[] jobIn,
                         String urlStr)
                  throws JobExecutionException
Throws:
JobExecutionException

getNodes

public List getNodes()
              throws MonitorException
Throws:
MonitorException

getNodeById

public Hashtable getNodeById(String nodeId)
                      throws MonitorException
Throws:
MonitorException

killJob

public boolean killJob(String jobId)
                throws MonitorException
Throws:
MonitorException

getExecutionNode

public String getExecutionNode(String jobId)

getQueues

public List<String> getQueues()
                       throws QueueManagerException
Throws:
QueueManagerException

addQueue

public boolean addQueue(String queueName)
                 throws QueueManagerException
Throws:
QueueManagerException

removeQueue

public boolean removeQueue(String queueName)
                    throws QueueManagerException
Throws:
QueueManagerException

addNode

public boolean addNode(Hashtable hashNode)
                throws MonitorException
Throws:
MonitorException

removeNode

public boolean removeNode(String nodeId)
                   throws MonitorException
Throws:
MonitorException

addNodeToQueue

public boolean addNodeToQueue(String nodeId,
                              String queueName)
                       throws QueueManagerException
Throws:
QueueManagerException

removeNodeFromQueue

public boolean removeNodeFromQueue(String nodeId,
                                   String queueName)
                            throws QueueManagerException
Throws:
QueueManagerException

getNodesInQueue

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

getQueuesWithNode

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

shutdown

public boolean shutdown()

getNodeLoad

public String getNodeLoad(String nodeId)
                   throws MonitorException
Throws:
MonitorException

main

public static void main(String[] args)
                 throws Exception
Throws:
Exception

setNodeCapacity

public boolean setNodeCapacity(String nodeId,
                               int capacity)
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 1999-2012 Apache OODT. All Rights Reserved.