wt.clients.workflow.engine
Class WfQueueManager

java.lang.Object
  wt.clients.workflow.engine.WfQueueManager

public class WfQueueManager

extends Object

This is a utility for managing workflow queues. Functionality includes some general queue functionality such as starting, stopping queues as well as workflow specific functionality, especially the following:

• displaying of the activity and workflow process the entry is associated with
• displaying the attribute values associated with the entry

The workflow queues supported by this utility are the following:

• Workflow propagation queue - mostly used for event propagation
• Workflow user work queue - used to carry out user defined work, such in the robots
• Workflow schedule queue - used by timer robots

This utility doesn't address dedicated workflow queues.

Supported API: true

Extendable: false

Field Summary

private static String	CHANGE_STATE
private static Vector	entryVector
private static String	PROCESS_DEADLINE
private static String	PROCESS_TIME_PAST_DEADLINE
private static String	PROCESS_TIME_TO_DEADLINE
private static String	PROPAGATE_EVENT
private static String	RESTORE_STATE
private static Timestamp	retrievalTime
private static String	RUN_ROBOT
private static boolean[]	selectedEntries
private static WtQueue	selectedQueue
private static String[]	statusCodeArray
private static String	SYNCHRONIZE
private static String	WORKFLOW_PROPAGATION_QUEUE_NAME
private static String	WORKFLOW_SCHEDULE_QUEUE_NAME
private static String	WORKFLOW_USER_WORK_QUEUE_NAME
private static ProcessingQueue	workflowPropagationQueue
private static ScheduleQueue	workflowScheduleQueue
private static ProcessingQueue	workflowUserWorkQueue

Constructor Summary

WfQueueManager()

Method Summary

private static void	changeEntryStatus(WtQueueEntry entry, String status)
private static void	changeStatusOfSelectedEntries()
static String	classToString(Class cls)
static String	connectorToString(WfConnector conn, boolean summary)
private static void	deleteSelectedEntries()
private static void	disableSelectedQueue()
private static void	enableSelectedQueue()
static String	execObjToString(WfExecutionObject exec_obj, boolean summary)
private static int	getChoice(int min, int max)
static String	getEntryDetail(WtQueueEntry entry)
static String	getEntryInfo(WtQueueEntry entry)
private static String	getEntrySummary(WtQueueEntry entry)
private static void	getQueueEntries()
private static String	isActive(WtQueue queue)
static void	main(String[] args)
static String	numberToString(int i, int size)
private static void	readQueues()
private static void	resetSelectedEntries()
private static void	selectAllEntries()
private static void	selectEntry()
private static void	showEntryDetail()
private static void	showQueueEntries()
private static void	showQueues()
private static void	startSelectedQueue()
private static void	stopSelectedQueue()
static String	wfObjToString(ObjectIdentifier node_id, boolean summary)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

WORKFLOW_PROPAGATION_QUEUE_NAME

private static final String WORKFLOW_PROPAGATION_QUEUE_NAME

See Also:

Constant Field Values

WORKFLOW_SCHEDULE_QUEUE_NAME

private static final String WORKFLOW_SCHEDULE_QUEUE_NAME

See Also:

Constant Field Values

WORKFLOW_USER_WORK_QUEUE_NAME

private static final String WORKFLOW_USER_WORK_QUEUE_NAME

See Also:

Constant Field Values

PROPAGATE_EVENT

private static final String PROPAGATE_EVENT

See Also:

Constant Field Values

CHANGE_STATE

private static final String CHANGE_STATE

See Also:

Constant Field Values

RESTORE_STATE

private static final String RESTORE_STATE

See Also:

Constant Field Values

RUN_ROBOT

private static final String RUN_ROBOT

See Also:

Constant Field Values

PROCESS_DEADLINE

private static final String PROCESS_DEADLINE

See Also:

Constant Field Values

PROCESS_TIME_TO_DEADLINE

private static final String PROCESS_TIME_TO_DEADLINE

See Also:

Constant Field Values

PROCESS_TIME_PAST_DEADLINE

private static final String PROCESS_TIME_PAST_DEADLINE

See Also:

Constant Field Values

SYNCHRONIZE

private static final String SYNCHRONIZE

See Also:

Constant Field Values

workflowPropagationQueue

private static ProcessingQueue workflowPropagationQueue

workflowUserWorkQueue

private static ProcessingQueue workflowUserWorkQueue

workflowScheduleQueue

private static ScheduleQueue workflowScheduleQueue

selectedQueue

private static WtQueue selectedQueue

selectedEntries

private static boolean[] selectedEntries

entryVector

private static Vector entryVector

retrievalTime

private static Timestamp retrievalTime

statusCodeArray

private static String[] statusCodeArray

Constructor Detail

WfQueueManager

public WfQueueManager()

Method Detail

readQueues

private static void readQueues()

showQueues

private static void showQueues()

getQueueEntries

private static void getQueueEntries()

showQueueEntries

private static void showQueueEntries()

main

public static void main(String[] args)
                 throws IOException

Throws:

IOException

resetSelectedEntries

private static void resetSelectedEntries()

changeStatusOfSelectedEntries

private static void changeStatusOfSelectedEntries()

changeEntryStatus

private static void changeEntryStatus(WtQueueEntry entry,
                                      String status)

deleteSelectedEntries

private static void deleteSelectedEntries()

isActive

private static String isActive(WtQueue queue)

startSelectedQueue

private static void startSelectedQueue()

enableSelectedQueue

private static void enableSelectedQueue()

disableSelectedQueue

private static void disableSelectedQueue()

stopSelectedQueue

private static void stopSelectedQueue()

selectEntry

private static void selectEntry()

selectAllEntries

private static void selectAllEntries()

getChoice

private static int getChoice(int min,
                             int max)

getEntrySummary

private static String getEntrySummary(WtQueueEntry entry)
                               throws WTException

Throws:

WTException

showEntryDetail

private static void showEntryDetail()

numberToString

public static String numberToString(int i,
                                    int size)

getEntryDetail

public static String getEntryDetail(WtQueueEntry entry)

getEntryInfo

public static String getEntryInfo(WtQueueEntry entry)

wfObjToString

public static String wfObjToString(ObjectIdentifier node_id,
                                   boolean summary)

classToString

public static String classToString(Class cls)

connectorToString

public static String connectorToString(WfConnector conn,
                                       boolean summary)

execObjToString

public static String execObjToString(WfExecutionObject exec_obj,
                                     boolean summary)