wt.queue
Class QueuePage

java.lang.Object
  wt.queue.QueuePage

All Implemented Interfaces:

QueueJspCons, RemoteAccess, Serializable

public class QueuePage

extends Object

implements QueueJspCons, Serializable, RemoteAccess

See Also:

Serialized Form

Field Summary

(package private) static boolean	SERVER
private static Vector	sysadm_names
private static int	WAIT_STATE_CHANGE

Fields inherited from interface wt.queue.QueueJspCons

DISABLE_Q, ENABLE_Q, NONE, PROCESS_Q, SCHEDULE_Q, START_Q, STARTED, STOP_Q, STOPPED, SUSPEND_Q, SUSPENDED

Fields inherited from interface wt.method.RemoteAccess

versionID

Constructor Summary

QueuePage()

Method Summary

void	addEntry(ProcessingQueue queue, WTPrincipal princ, String tMethod, String tClass, Class[] argTypes, Object[] args) Adds an Entry to the given processing queue.
void	addEntry(ScheduleQueue queue, WTPrincipal princ, String tMethod, String tClass, Class[] argTypes, Object[] args, Timestamp futureTime) Adds an Entry to the given schedule queue.
void	createQueue(String q_name, String q_type, String exe_host)
void	deleteEntry(QueueInfo qi, QueueEntryInfo qei)
void	deleteQueue(String q_name, String q_type)
void	deleteWithStatus(String q_name, String q_type, String status)
QueueInfo	disableQueue(String queue_name, String queue_type)
QueueInfo	enableQueue(String queue_name, String queue_type)
Vector	getEntries(String queue_name, String type)
Vector	getEntries(String queue_name, String type, String status)
private static Manager	getManager()
private static Manager	getManager(Class a_manager)
Vector	getQueueEntries(String queue_name, String type)
Vector	getQueueEntries(String queue_name, String type, String status)
Enumeration	getQueueEnumeration()
TreeSet	getQueues()
void	getQueues(TreeSet qz, Class qtype)
boolean	isSysAdminMember()
private void	resetEntries(String q_name, String to, Enumeration entries)
void	setExceptionRetries(String q_name, String q_type, String retries)
void	setNotificationEmail(String q_name, String q_type, String email)
void	setPollingInterval(String q_name, String q_type, String newInterval)
QueueInfo	setQueueExecutionHost(String q_name, String q_type, String new_host)
void	setQueueName(String q_name, String prev_name, String q_type)
void	setSuspendDuration(String q_name, String q_type, String duration)
void	startAllQueues()
QueueInfo	startQueue(String queue_name, String queue_type)
void	stopAllQueues()
QueueInfo	stopQueue(String queue_name, String queue_type)
QueueInfo	suspendQueue(String queue_name, String queue_type)
void	updateEntry(UpdateEntry ue)
void	updateQueueEntries(String q_name, String q_type, String from, String to)

Methods inherited from class java.lang.Object

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

Field Detail

SERVER

static final boolean SERVER

sysadm_names

private static Vector sysadm_names

WAIT_STATE_CHANGE

private static int WAIT_STATE_CHANGE

Constructor Detail

QueuePage

public QueuePage()

Method Detail

getManager

private static Manager getManager()
                           throws WTException

Throws:

WTException

getManager

private static Manager getManager(Class a_manager)
                           throws WTException

Throws:

WTException

getQueues

public TreeSet getQueues()
                  throws WTException

Throws:

WTException

getQueues

public void getQueues(TreeSet qz,
                      Class qtype)
               throws WTException

Throws:

WTException

getQueueEnumeration

public Enumeration getQueueEnumeration()
                                throws WTException

Throws:

WTException

getQueueEntries

public Vector getQueueEntries(String queue_name,
                              String type)
                       throws WTException

Throws:

WTException

getEntries

public Vector getEntries(String queue_name,
                         String type)
                  throws WTException

Throws:

WTException

getQueueEntries

public Vector getQueueEntries(String queue_name,
                              String type,
                              String status)
                       throws WTException

Throws:

WTException

getEntries

public Vector getEntries(String queue_name,
                         String type,
                         String status)
                  throws WTException

Throws:

WTException

startAllQueues

public void startAllQueues()
                    throws WTException

Throws:

WTException

stopAllQueues

public void stopAllQueues()
                   throws WTException

Throws:

WTException

createQueue

public void createQueue(String q_name,
                        String q_type,
                        String exe_host)
                 throws WTException

Throws:

WTException

deleteQueue

public void deleteQueue(String q_name,
                        String q_type)
                 throws WTException

Throws:

WTException

startQueue

public QueueInfo startQueue(String queue_name,
                            String queue_type)
                     throws WTException

Throws:

WTException

stopQueue

public QueueInfo stopQueue(String queue_name,
                           String queue_type)
                    throws WTException

Throws:

WTException

enableQueue

public QueueInfo enableQueue(String queue_name,
                             String queue_type)
                      throws WTException

Throws:

WTException

disableQueue

public QueueInfo disableQueue(String queue_name,
                              String queue_type)
                       throws WTException

Throws:

WTException

suspendQueue

public QueueInfo suspendQueue(String queue_name,
                              String queue_type)
                       throws WTException

Throws:

WTException

setQueueName

public void setQueueName(String q_name,
                         String prev_name,
                         String q_type)
                  throws WTException

Throws:

WTException

setQueueExecutionHost

public QueueInfo setQueueExecutionHost(String q_name,
                                       String q_type,
                                       String new_host)
                                throws WTException

Throws:

WTException

updateQueueEntries

public void updateQueueEntries(String q_name,
                               String q_type,
                               String from,
                               String to)
                        throws WTException

Throws:

WTException

resetEntries

private void resetEntries(String q_name,
                          String to,
                          Enumeration entries)
                   throws WTException

Throws:

WTException

deleteWithStatus

public void deleteWithStatus(String q_name,
                             String q_type,
                             String status)
                      throws WTException

Throws:

WTException

deleteEntry

public void deleteEntry(QueueInfo qi,
                        QueueEntryInfo qei)
                 throws WTException

Throws:

WTException

updateEntry

public void updateEntry(UpdateEntry ue)
                 throws WTException

Throws:

WTException

setPollingInterval

public void setPollingInterval(String q_name,
                               String q_type,
                               String newInterval)
                        throws WTException

Throws:

WTException

setExceptionRetries

public void setExceptionRetries(String q_name,
                                String q_type,
                                String retries)
                         throws WTException

Throws:

WTException

setNotificationEmail

public void setNotificationEmail(String q_name,
                                 String q_type,
                                 String email)
                          throws WTException

Throws:

WTException

setSuspendDuration

public void setSuspendDuration(String q_name,
                               String q_type,
                               String duration)
                        throws WTException

Throws:

WTException

addEntry

public void addEntry(ProcessingQueue queue,
                     WTPrincipal princ,
                     String tMethod,
                     String tClass,
                     Class[] argTypes,
                     Object[] args)
              throws WTException

Adds an Entry to the given processing queue. Method added for queue test suite.

Throws:

WTException

addEntry

public void addEntry(ScheduleQueue queue,
                     WTPrincipal princ,
                     String tMethod,
                     String tClass,
                     Class[] argTypes,
                     Object[] args,
                     Timestamp futureTime)
              throws WTException

Adds an Entry to the given schedule queue. Method added for queue test suite.

Throws:

WTException

isSysAdminMember

public boolean isSysAdminMember()
                         throws WTException

Throws:

WTException