|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface IProcessQueueManagerSPI
Manager that controls the consumption part of a queue.
Method Summary | |
---|---|
IQueueTaskProcess |
getNextQueuedItem()
Retrieves the next QueueItem that is queued state or is in scheduled but the scheduled time has already passed and sets its status to InProgress. |
IQueueTaskProcess |
getNextScheduledProcess()
Returns the next scheduled IQueueItem. |
void |
removeFromQueue(IQueueTaskProcess item,
boolean notifyListeners)
Removes from queue the current item. |
void |
setFailedStatus(IQueueTaskProcess queueItem)
Sets the given process the status of QueueTaskProcessStatus.Failed . |
void |
waitForQueueReadyToProcess(long timeout)
Informs the thread that is is supposed to wait for a process to enter queue or wait timeout before waking up. |
Methods inherited from interface lumis.portal.processqueue.IProcessQueueManager |
---|
getQueueStatistics, getTaskProcess, reprocess, schedule, schedule, send, send, send, send |
Method Detail |
---|
IQueueTaskProcess getNextQueuedItem() throws PortalException
PortalException
void removeFromQueue(IQueueTaskProcess item, boolean notifyListeners) throws PortalException
item
- to be removed from queue.notifyListeners
- if the threads should be waken up.
PortalException
void setFailedStatus(IQueueTaskProcess queueItem) throws PortalException
QueueTaskProcessStatus.Failed
.
queueItem
- item to be put in failed status.
PortalException
IQueueTaskProcess getNextScheduledProcess() throws PortalException
PortalException
void waitForQueueReadyToProcess(long timeout) throws InterruptedException
timeout
- max time to wait for a process to enter the queue.
InterruptedException
- when the thread is waken.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |