Uses of Class
wt.queue.WtQueue

Packages that use WtQueue

com.ptc.wvs.server.publish
wt.clients.workflow.engine
wt.queue	Overview
wt.workflow.engine	Provides workflow classes responsible for the flow of control and data from an execution point of view.

Uses of WtQueue in com.ptc.wvs.server.publish

Methods in com.ptc.wvs.server.publish that return WtQueue

static WtQueue	PublishQueueHelper.createQueue(String queueName) Creates a new processing queue.
private static WtQueue	PublishQueueHelper.findAvailableQueue(String queueName)

Methods in com.ptc.wvs.server.publish with parameters of type WtQueue

private static Boolean	PublishQueueHelper.addEntry(WtQueue queue, Collection collection) Adds a job to the specified queue Supported API: false
private static Boolean	PublishQueueHelper.addEntry(WtQueue queue, PublishJob publishJob)
static QueryResult	PublishQueueHelper.getQueueEntries(WtQueue queue)

Uses of WtQueue in wt.clients.workflow.engine

Fields in wt.clients.workflow.engine declared as WtQueue

private static WtQueue

WfQueueManager.selectedQueue

Methods in wt.clients.workflow.engine with parameters of type WtQueue

private static String

WfQueueManager.isActive(WtQueue queue)

Uses of WtQueue in wt.queue

Subclasses of WtQueue in wt.queue

class	ProcessingQueue The ProcessingQueue represents a specific (named) processing queue.
class	ScheduleQueue Use the newScheduleQueue static factory method(s), not the ScheduleQueue constructor, to construct instances of this class.

Fields in wt.queue declared as WtQueue

(package private) WtQueue	WtQueue.QueueCacheUpdater.wtq
private WtQueue	ScheduleQueueThread.qu
(package private) WtQueue	QueueWatcher.q
private static WtQueue	QueueManager.selectedQueue
(package private) WtQueue	WtQueue.QueueCacheUpdater.wtq
private WtQueue	ScheduleQueueThread.qu
(package private) WtQueue	QueueWatcher.q
private static WtQueue	QueueManager.selectedQueue

Methods in wt.queue that return WtQueue

WtQueue	WtQueue.refresh() Supported API: false
WtQueue	StandardQueueService.getQueue(String queue_name, Class queue_type) Supported API: false
WtQueue	QueueWatcher.getQueue() returns the queue instance held by this QueueWatcher Supported API: false
WtQueue	QueueServiceFwd.getQueue(String queue_name, Class queue_type) Supported API: false
WtQueue	QueueService.getQueue(String queue_name, Class queue_type) Supported API: false
static WtQueue	QueueMonitorHelper.getWtQueue(WtQueue q) Get an instance of WtQueue Supported API: false
static WtQueue	QueueMonitorHelper.getWtQueue(String name, Class type) Get an instance of WtQueue Supported API: false
WtQueue	QueueMonitorHelper.deleteQueue(WtQueue queue) Deletes a queue first stop the queue delete associated queue enties finally delete the queue and signal a queue modification Supported API: false
WtQueue	QueueMonitorHelper.refreshQueue(WtQueue queue) Refresh a queue instance Supported API: false
WtQueue	WtQueue.refresh() Supported API: false
WtQueue	StandardQueueService.getQueue(String queue_name, Class queue_type) Supported API: false
WtQueue	QueueWatcher.getQueue() returns the queue instance held by this QueueWatcher Supported API: false
WtQueue	QueueServiceFwd.getQueue(String queue_name, Class queue_type) Supported API: false
WtQueue	QueueService.getQueue(String queue_name, Class queue_type) Supported API: false
static WtQueue	QueueMonitorHelper.getWtQueue(WtQueue q) Get an instance of WtQueue Supported API: false
static WtQueue	QueueMonitorHelper.getWtQueue(String name, Class type) Get an instance of WtQueue Supported API: false
WtQueue	QueueMonitorHelper.deleteQueue(WtQueue queue) Deletes a queue first stop the queue delete associated queue enties finally delete the queue and signal a queue modification Supported API: false
WtQueue	QueueMonitorHelper.refreshQueue(WtQueue queue) Refresh a queue instance Supported API: false

Methods in wt.queue with parameters of type WtQueue

protected boolean	WtQueue.readVersion(WtQueue thisObject, ObjectInput input, long readSerialVersionUID, boolean passThrough, boolean superDone) Reads the non-transient fields of this class from an external source.
void	StandardQueueService.updateQueueEntry(WtQueue queue, UpdateEntry entryInfo) Supported API: false
void	StandardQueueService.setPollingInterval(WtQueue queue, String interval) Supported API: false
void	StandardQueueService.setSuspendDuration(WtQueue queue, String duration) Supported API: false
void	StandardQueueService.setExceptionRetries(WtQueue queue, String retries) Supported API: false
void	StandardQueueService.setFailureNotificationEmail(WtQueue queue, String email) Supported API: false
private void	StandardQueueMonitor.checkQueueProperties(String queueName, WtQueue queue)
void	StandardQueueMonitor.queueHealthCheck(WtQueue aq, QueueWatcher qw)
private void	StandardQueueMonitor.setQueueState(WtQueue q, String state)
void	ScheduleQueueThread.setQueue(WtQueue queue)
private void	QueueWatcher.refreshQueueWatcher(WtQueue queue) Synchronized method which refreshes the queue instance held by this queue watcher Supported API: false
void	QueueWatcher.updateState(WtQueue queue) update a queues state information Supported API: false
private void	QueueWatcher.setQueueState(WtQueue queue, String state) method which sets and saves a queues running state Supported API: false
void	QueueServiceFwd.updateQueueEntry(WtQueue queue, UpdateEntry entryInfo) Supported API: false
void	QueueServiceFwd.setPollingInterval(WtQueue queue, String interval) Supported API: false
void	QueueServiceFwd.setSuspendDuration(WtQueue queue, String duration) Supported API: false
void	QueueServiceFwd.setExceptionRetries(WtQueue queue, String retries) Supported API: false
void	QueueServiceFwd.setFailureNotificationEmail(WtQueue queue, String email) Supported API: false
void	QueueService.updateQueueEntry(WtQueue queue, UpdateEntry entryInfo) Supported API: false
void	QueueService.setPollingInterval(WtQueue queue, String interval) Supported API: false
void	QueueService.setSuspendDuration(WtQueue queue, String duration) Supported API: false
void	QueueService.setExceptionRetries(WtQueue queue, String retries) Supported API: false
void	QueueService.setFailureNotificationEmail(WtQueue queue, String email) Supported API: false
private static Boolean	QueueMonitorHelper.getThisHost(WtQueue queue) Determines if a queue executes on this host based on persistent host attribute Note: The persistent host attribute take presidence over a wt.properties host entry for a given queue Supported API: false
private static Boolean	QueueMonitorHelper.checkQueueHost(Boolean qHost, WtQueue queue) check to see if queue execution host has changed Supported API: false
boolean	QueueMonitorHelper.thisQueueThisHost(String queue, WtQueue aQueue) Determines if queue should run on this server Supported API: false
boolean	QueueMonitorHelper.isActive(WtQueue aQueue) Determines if queue is active Supported API: false
static WtQueue	QueueMonitorHelper.getWtQueue(WtQueue q) Get an instance of WtQueue Supported API: false
static void	QueueMonitorHelper.setQueueEnabled(WtQueue aQueue, boolean desired) Set a queue's enabled state Supported API: false
void	QueueMonitorHelper.createQueue(WtQueue queue) Saves a queue and emmits a queue modification signal Supported API: false
WtQueue	QueueMonitorHelper.deleteQueue(WtQueue queue) Deletes a queue first stop the queue delete associated queue enties finally delete the queue and signal a queue modification Supported API: false
WtQueue	QueueMonitorHelper.refreshQueue(WtQueue queue) Refresh a queue instance Supported API: false
boolean	QueueMonitorHelper.queueStopped(WtQueue queue) Check to see if a queue has been stopped Supported API: false
boolean	QueueMonitorHelper.checkQSS(WtQueue queue) Check to see if a queue has been started Supported API: false
void	QueueMonitorHelper.deleteEntries(WtQueue queue) Delete a queues entries Supported API: false
void	QueueMonitorHelper.deleteEntries(WtQueue queue, String status_code) Delete a queues entries with a specific status code Supported API: false
Enumeration	QueueMonitorHelper.queueEntries(WtQueue queue) Get a queues entries Supported API: false
void	QueueMonitorHelper.setQueueExecutionHost(WtQueue queue, String hostName) Set a queues execution host Supported API: false
void	QueueMonitorHelper.stopQueue(WtQueue queue) Stop a queue Supported API: false
void	QueueMonitorHelper.startQueue(WtQueue queue) Start a queue Supported API: false
boolean	QueueMonitorHelper.okToStartStop(WtQueue queue) Check to see if this queue is controlable Supported API: false
void	QueueMonitorHelper.updateEntry(WtQueue queue, UpdateEntry ue)
void	QueueMonitorHelper.resetAllEntries(WtQueue queue, Class q_class)
private static String	QueueManager.isActive(Class qtype, WtQueue queue)
void	PollingQueueThread.setQueue(WtQueue queue)
protected boolean	WtQueue.readVersion(WtQueue thisObject, ObjectInput input, long readSerialVersionUID, boolean passThrough, boolean superDone) Reads the non-transient fields of this class from an external source.
void	StandardQueueService.updateQueueEntry(WtQueue queue, UpdateEntry entryInfo) Supported API: false
void	StandardQueueService.setPollingInterval(WtQueue queue, String interval) Supported API: false
void	StandardQueueService.setSuspendDuration(WtQueue queue, String duration) Supported API: false
void	StandardQueueService.setExceptionRetries(WtQueue queue, String retries) Supported API: false
void	StandardQueueService.setFailureNotificationEmail(WtQueue queue, String email) Supported API: false
private void	StandardQueueMonitor.checkQueueProperties(String queueName, WtQueue queue)
void	StandardQueueMonitor.queueHealthCheck(WtQueue aq, QueueWatcher qw)
private void	StandardQueueMonitor.setQueueState(WtQueue q, String state)
void	ScheduleQueueThread.setQueue(WtQueue queue)
private void	QueueWatcher.refreshQueueWatcher(WtQueue queue) Synchronized method which refreshes the queue instance held by this queue watcher Supported API: false
void	QueueWatcher.updateState(WtQueue queue) update a queues state information Supported API: false
private void	QueueWatcher.setQueueState(WtQueue queue, String state) method which sets and saves a queues running state Supported API: false
void	QueueServiceFwd.updateQueueEntry(WtQueue queue, UpdateEntry entryInfo) Supported API: false
void	QueueServiceFwd.setPollingInterval(WtQueue queue, String interval) Supported API: false
void	QueueServiceFwd.setSuspendDuration(WtQueue queue, String duration) Supported API: false
void	QueueServiceFwd.setExceptionRetries(WtQueue queue, String retries) Supported API: false
void	QueueServiceFwd.setFailureNotificationEmail(WtQueue queue, String email) Supported API: false
void	QueueService.updateQueueEntry(WtQueue queue, UpdateEntry entryInfo) Supported API: false
void	QueueService.setPollingInterval(WtQueue queue, String interval) Supported API: false
void	QueueService.setSuspendDuration(WtQueue queue, String duration) Supported API: false
void	QueueService.setExceptionRetries(WtQueue queue, String retries) Supported API: false
void	QueueService.setFailureNotificationEmail(WtQueue queue, String email) Supported API: false
private static Boolean	QueueMonitorHelper.getThisHost(WtQueue queue) Determines if a queue executes on this host based on persistent host attribute Note: The persistent host attribute take presidence over a wt.properties host entry for a given queue Supported API: false
private static Boolean	QueueMonitorHelper.checkQueueHost(Boolean qHost, WtQueue queue) check to see if queue execution host has changed Supported API: false
boolean	QueueMonitorHelper.thisQueueThisHost(String queue, WtQueue aQueue) Determines if queue should run on this server Supported API: false
boolean	QueueMonitorHelper.isActive(WtQueue aQueue) Determines if queue is active Supported API: false
static WtQueue	QueueMonitorHelper.getWtQueue(WtQueue q) Get an instance of WtQueue Supported API: false
static void	QueueMonitorHelper.setQueueEnabled(WtQueue aQueue, boolean desired) Set a queue's enabled state Supported API: false
void	QueueMonitorHelper.createQueue(WtQueue queue) Saves a queue and emmits a queue modification signal Supported API: false
WtQueue	QueueMonitorHelper.deleteQueue(WtQueue queue) Deletes a queue first stop the queue delete associated queue enties finally delete the queue and signal a queue modification Supported API: false
WtQueue	QueueMonitorHelper.refreshQueue(WtQueue queue) Refresh a queue instance Supported API: false
boolean	QueueMonitorHelper.queueStopped(WtQueue queue) Check to see if a queue has been stopped Supported API: false
boolean	QueueMonitorHelper.checkQSS(WtQueue queue) Check to see if a queue has been started Supported API: false
void	QueueMonitorHelper.deleteEntries(WtQueue queue) Delete a queues entries Supported API: false
void	QueueMonitorHelper.deleteEntries(WtQueue queue, String status_code) Delete a queues entries with a specific status code Supported API: false
Enumeration	QueueMonitorHelper.queueEntries(WtQueue queue) Get a queues entries Supported API: false
void	QueueMonitorHelper.setQueueExecutionHost(WtQueue queue, String hostName) Set a queues execution host Supported API: false
void	QueueMonitorHelper.stopQueue(WtQueue queue) Stop a queue Supported API: false
void	QueueMonitorHelper.startQueue(WtQueue queue) Start a queue Supported API: false
boolean	QueueMonitorHelper.okToStartStop(WtQueue queue) Check to see if this queue is controlable Supported API: false
void	QueueMonitorHelper.updateEntry(WtQueue queue, UpdateEntry ue)
void	QueueMonitorHelper.resetAllEntries(WtQueue queue, Class q_class)
private static String	QueueManager.isActive(Class qtype, WtQueue queue)
void	PollingQueueThread.setQueue(WtQueue queue)

Constructors in wt.queue with parameters of type WtQueue

WtQueue.QueueCacheUpdater(WtQueue wtq)

ScheduleQueueThread(WtQueue q)

QueueWatcher(WtQueue queue, boolean enabled, boolean host)
Constructor

Supported API: false

QueueInfo(WtQueue qu)

PollingQueueThread(long interval, WtQueue aQueue)
PollingQueueThread public constructor

Supported API: true

WtQueue.QueueCacheUpdater(WtQueue wtq)

ScheduleQueueThread(WtQueue q)

QueueWatcher(WtQueue queue, boolean enabled, boolean host)
Constructor

Supported API: false

QueueInfo(WtQueue qu)

PollingQueueThread(long interval, WtQueue aQueue)
PollingQueueThread public constructor

Supported API: true

Uses of WtQueue in wt.workflow.engine

Methods in wt.workflow.engine with parameters of type WtQueue

WtQueueEntry	StandardWfEngineService.getQueueEntry(WtQueue queue, long entryNumber)
WtQueueEntry	StandardWfEngineService.getQueueEntry(WtQueue queue, long entryNumber)