wt.queue
Class StandardQueueMonitor

java.lang.Object
  java.lang.Thread
      wt.queue.StandardQueueMonitor

All Implemented Interfaces:

QueueMonitor, Runnable

public class StandardQueueMonitor

extends Thread

implements QueueMonitor

Nested Class Summary

(package private) class

StandardQueueMonitor.CheckerThread

Field Summary

(package private) StandardQueueMonitor.CheckerThread	checkerThread
private static String	CODE
private static String	CODEC5
private Hashtable	processQueues
private static WTProperties	properties
private static String	QUEUE_MONITOR_HOST
private QueueMonitorHelper	queueMonitorHelper
private static boolean	RUNNER_CHECK
private static boolean	RUNNER_RESTART
private Hashtable	scheduleQueues
private static boolean	SHOW_QUEUES
private static int	SLEEP_TIME
private static boolean	VERBOSE

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Fields inherited from interface wt.queue.QueueMonitor

MAX_PROCESS_QUEUES, MAX_SCHEDULE_QUEUES, PROCESS, Q_MODIFICATION, Q_NOT_STARTED, Q_NOT_STOPPED, RECALCULATE, STATE

Constructor Summary

StandardQueueMonitor()

Method Summary

private void	checkQueueProperties(String queueName, WtQueue queue)
private void	checkQueues(Hashtable queues, Class queue_type)
private void	deletedQueues(Hashtable activeQueues, Hashtable queues)
private ProcessingQueue	getQueue(String name)
private Enumeration	getQueues(Class queue_type)
private void	initQueue(Class queue_type, Hashtable queues)
private Hashtable	newQueues(Enumeration qz, Hashtable queues)
void	queueHealthCheck(WtQueue aq, QueueWatcher qw)
private void	resetExecEntries(String table_name, Class queue_type)
void	run()
private void	setQueueState(WtQueue q, String state)
private void	showQueueProperties()
void	showQueues(Hashtable queues)
void	startQueueProcessing()
private void	startRunner(Enumeration e)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_MONITOR_HOST

private static String QUEUE_MONITOR_HOST

VERBOSE

private static boolean VERBOSE

SLEEP_TIME

private static int SLEEP_TIME

SHOW_QUEUES

private static boolean SHOW_QUEUES

RUNNER_RESTART

private static boolean RUNNER_RESTART

RUNNER_CHECK

private static boolean RUNNER_CHECK

CODE

private static final String CODE

See Also:

Constant Field Values

CODEC5

private static final String CODEC5

See Also:

Constant Field Values

processQueues

private Hashtable processQueues

scheduleQueues

private Hashtable scheduleQueues

queueMonitorHelper

private QueueMonitorHelper queueMonitorHelper

checkerThread

StandardQueueMonitor.CheckerThread checkerThread

properties

private static WTProperties properties

Constructor Detail

StandardQueueMonitor

public StandardQueueMonitor()
                     throws WTException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

resetExecEntries

private void resetExecEntries(String table_name,
                              Class queue_type)
                       throws WTException

Throws:

WTException

initQueue

private void initQueue(Class queue_type,
                       Hashtable queues)
                throws WTException

Throws:

WTException

checkQueueProperties

private void checkQueueProperties(String queueName,
                                  WtQueue queue)
                           throws WTException

Throws:

WTException

checkQueues

private void checkQueues(Hashtable queues,
                         Class queue_type)

newQueues

private Hashtable newQueues(Enumeration qz,
                            Hashtable queues)
                     throws WTException

Throws:

WTException

queueHealthCheck

public void queueHealthCheck(WtQueue aq,
                             QueueWatcher qw)

deletedQueues

private void deletedQueues(Hashtable activeQueues,
                           Hashtable queues)

getQueues

private Enumeration getQueues(Class queue_type)
                       throws WTException

Throws:

WTException

getQueue

private ProcessingQueue getQueue(String name)
                          throws WTException

Throws:

WTException

showQueueProperties

private void showQueueProperties()

showQueues

public void showQueues(Hashtable queues)

setQueueState

private void setQueueState(WtQueue q,
                           String state)
                    throws WTException

Throws:

WTException

startQueueProcessing

public void startQueueProcessing()
                          throws WTException

Throws:

WTException

startRunner

private void startRunner(Enumeration e)
                  throws WTException

Throws:

WTException