org.apache.oodt.cas.workflow.system
Class XmlRpcWorkflowManager

java.lang.Object
  extended by org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManager

public class XmlRpcWorkflowManager
extends Object

Version:
$Revision$

An XML RPC-based Workflow manager.

Author:
mattmann

Constructor Summary
XmlRpcWorkflowManager(int port)
           
 
Method Summary
 Hashtable getConditionById(String conditionId)
           
 Hashtable getFirstPage()
           
 Hashtable getLastPage()
           
 Hashtable getNextPage(Hashtable currentPage)
           
 int getNumWorkflowInstances()
           
 int getNumWorkflowInstancesByStatus(String status)
           
 Hashtable getPrevPage(Hashtable currentPage)
           
 Vector getRegisteredEvents()
           
 Hashtable getTaskById(String taskId)
           
 Hashtable getWorkflowById(String workflowId)
           
 double getWorkflowCurrentTaskWallClockMinutes(String workflowInstId)
           
 Hashtable getWorkflowInstanceById(String wInstId)
           
 Hashtable getWorkflowInstanceMetadata(String wInstId)
           
 Vector getWorkflowInstances()
           
 Vector getWorkflowInstancesByStatus(String status)
           
 Vector getWorkflows()
           
 Vector getWorkflowsByEvent(String eventName)
           
 double getWorkflowWallClockMinutes(String workflowInstId)
           
 boolean handleEvent(String eventName, Hashtable metadata)
           
static void main(String[] args)
           
 Hashtable paginateWorkflowInstances(int pageNum)
           
 Hashtable paginateWorkflowInstances(int pageNum, String status)
           
 boolean pauseWorkflowInstance(String workflowInstId)
           
 boolean resumeWorkflowInstance(String workflowInstId)
           
 boolean setWorkflowInstanceCurrentTaskEndDateTime(String wInstId, String endDateTimeIsoStr)
           
 boolean setWorkflowInstanceCurrentTaskStartDateTime(String wInstId, String startDateTimeIsoStr)
           
 boolean stopWorkflowInstance(String workflowInstId)
           
 boolean updateMetadataForWorkflow(String workflowInstId, Hashtable metadata)
           
 boolean updateWorkflowInstance(Hashtable workflowInst)
           
 boolean updateWorkflowInstanceStatus(String workflowInstanceId, String status)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

XmlRpcWorkflowManager

public XmlRpcWorkflowManager(int port)
                      throws Exception
Parameters:
port - The web server port to run the XML Rpc server on, defaults to 2000.
Throws:
Exception
Method Detail

getRegisteredEvents

public Vector getRegisteredEvents()
                           throws RepositoryException
Throws:
RepositoryException

getFirstPage

public Hashtable getFirstPage()

getNextPage

public Hashtable getNextPage(Hashtable currentPage)

getPrevPage

public Hashtable getPrevPage(Hashtable currentPage)

getLastPage

public Hashtable getLastPage()

paginateWorkflowInstances

public Hashtable paginateWorkflowInstances(int pageNum,
                                           String status)
                                    throws InstanceRepositoryException
Throws:
InstanceRepositoryException

paginateWorkflowInstances

public Hashtable paginateWorkflowInstances(int pageNum)
                                    throws InstanceRepositoryException
Throws:
InstanceRepositoryException

getWorkflowInstanceMetadata

public Hashtable getWorkflowInstanceMetadata(String wInstId)

getWorkflowsByEvent

public Vector getWorkflowsByEvent(String eventName)
                           throws RepositoryException
Throws:
RepositoryException

handleEvent

public boolean handleEvent(String eventName,
                           Hashtable metadata)
                    throws RepositoryException,
                           EngineException
Throws:
RepositoryException
EngineException

getWorkflowInstanceById

public Hashtable getWorkflowInstanceById(String wInstId)
                                  throws EngineException
Throws:
EngineException

stopWorkflowInstance

public boolean stopWorkflowInstance(String workflowInstId)

pauseWorkflowInstance

public boolean pauseWorkflowInstance(String workflowInstId)

resumeWorkflowInstance

public boolean resumeWorkflowInstance(String workflowInstId)

getWorkflowWallClockMinutes

public double getWorkflowWallClockMinutes(String workflowInstId)

getWorkflowCurrentTaskWallClockMinutes

public double getWorkflowCurrentTaskWallClockMinutes(String workflowInstId)

getNumWorkflowInstancesByStatus

public int getNumWorkflowInstancesByStatus(String status)
                                    throws InstanceRepositoryException
Throws:
InstanceRepositoryException

getNumWorkflowInstances

public int getNumWorkflowInstances()
                            throws InstanceRepositoryException
Throws:
InstanceRepositoryException

getWorkflowInstancesByStatus

public Vector getWorkflowInstancesByStatus(String status)
                                    throws EngineException
Throws:
EngineException

getWorkflowInstances

public Vector getWorkflowInstances()
                            throws EngineException
Throws:
EngineException

getWorkflows

public Vector getWorkflows()
                    throws RepositoryException
Throws:
RepositoryException

getTaskById

public Hashtable getTaskById(String taskId)
                      throws RepositoryException
Throws:
RepositoryException

getConditionById

public Hashtable getConditionById(String conditionId)
                           throws RepositoryException
Throws:
RepositoryException

getWorkflowById

public Hashtable getWorkflowById(String workflowId)
                          throws RepositoryException
Throws:
RepositoryException

updateMetadataForWorkflow

public boolean updateMetadataForWorkflow(String workflowInstId,
                                         Hashtable metadata)

updateWorkflowInstance

public boolean updateWorkflowInstance(Hashtable workflowInst)

setWorkflowInstanceCurrentTaskStartDateTime

public boolean setWorkflowInstanceCurrentTaskStartDateTime(String wInstId,
                                                           String startDateTimeIsoStr)

setWorkflowInstanceCurrentTaskEndDateTime

public boolean setWorkflowInstanceCurrentTaskEndDateTime(String wInstId,
                                                         String endDateTimeIsoStr)

updateWorkflowInstanceStatus

public boolean updateWorkflowInstanceStatus(String workflowInstanceId,
                                            String status)
                                     throws Exception
Throws:
Exception

main

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


Copyright © 1999-2011 Apache OODT. All Rights Reserved.