wt.queue
Class ProcessQueueDriver

java.lang.Object
  extended bywt.queue.ProcessQueueDriver
All Implemented Interfaces:
RemoteAccess, Serializable

public class ProcessQueueDriver
extends Object
implements Serializable, RemoteAccess

Test driver class to manipulate processingQueues

See Also:
Serialized Form

Field Summary
private static QueueServiceFwd qsf
           
(package private) static boolean SERVER
           
 
Fields inherited from interface wt.method.RemoteAccess
versionID
 
Constructor Summary
ProcessQueueDriver()
           
 
Method Summary
 void addEntry(String queue_name, String target_class, String target_method)
           
 void addEntry(String queue_name, String target_class, String target_method, int count)
           
 void addMultiEntry(String queue_name, String target_class, String target_method, Integer count)
           
 void countQueues()
           
 ProcessingQueue createQueue(String queue_name)
           
 ProcessingQueue deleteQueue(String queue_name)
           
 void enableQueue(String queue_name, boolean enabled)
           
private static Manager getManager()
           
static void main(String[] args)
           
 void startQueue(String queue_name)
           
 void stopQueue(String queue_name)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

qsf

private static QueueServiceFwd qsf

SERVER

static final boolean SERVER
Constructor Detail

ProcessQueueDriver

public ProcessQueueDriver()
Method Detail

getManager

private static Manager getManager()
                           throws WTException
Throws:
WTException

createQueue

public ProcessingQueue createQueue(String queue_name)
                            throws WTException
Throws:
WTException

deleteQueue

public ProcessingQueue deleteQueue(String queue_name)
                            throws WTException
Throws:
WTException

startQueue

public void startQueue(String queue_name)
                throws WTException
Throws:
WTException

stopQueue

public void stopQueue(String queue_name)
               throws WTException
Throws:
WTException

enableQueue

public void enableQueue(String queue_name,
                        boolean enabled)
                 throws WTException
Throws:
WTException

countQueues

public void countQueues()
                 throws WTException
Throws:
WTException

addEntry

public void addEntry(String queue_name,
                     String target_class,
                     String target_method)
              throws WTException
Throws:
WTException

addEntry

public void addEntry(String queue_name,
                     String target_class,
                     String target_method,
                     int count)
              throws WTException
Throws:
WTException

addMultiEntry

public void addMultiEntry(String queue_name,
                          String target_class,
                          String target_method,
                          Integer count)
                   throws WTException
Throws:
WTException

main

public static void main(String[] args)