|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectto.etc.webapp.pendingoperations.PendingOperationTaskProvider
public class PendingOperationTaskProvider
This polled task provider checks for tasks to execute in the sys_pending_operations table. It handles all polling chores and properly handles all order requirements for pending operations. Operations here are checked only every 5 minutes.
Method Summary | |
---|---|
void |
addListener(IPendingOperationListener l)
|
IPendingOperationExecutor |
findExecutor(PendingOperation po)
Find an executor for a given pendingOperation type. |
static PendingOperationTaskProvider |
getInstance()
|
java.lang.Runnable |
getRunnableTask()
This checks for a new pending operation to execute. |
static void |
initialize(javax.sql.DataSource ds,
java.lang.String serverID)
Initializes this thing, and adds it to the worker queue handler. |
void |
initializeOnRegistration(PollingWorkerQueue pwq)
|
void |
registerPendingOperationType(java.lang.String type,
IPendingOperationExecutor pox)
Register a pending operation type and it's executor. |
void |
removeListener(IPendingOperationListener l)
|
void |
saveOperation(PendingOperation po,
java.io.Serializable object)
Store a PendingOperation in the table, or die. |
void |
saveOperation(PendingOperation po,
StringInputStream sis)
Store a PendingOperation in the table, or die. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public static void initialize(javax.sql.DataSource ds, java.lang.String serverID)
serverID
- public static PendingOperationTaskProvider getInstance()
public void addListener(IPendingOperationListener l)
public void removeListener(IPendingOperationListener l)
public void initializeOnRegistration(PollingWorkerQueue pwq) throws java.lang.Exception
initializeOnRegistration
in interface IPollQueueTaskProvider
java.lang.Exception
public java.lang.Runnable getRunnableTask() throws java.lang.Exception
getRunnableTask
in interface IPollQueueTaskProvider
java.lang.Exception
IPollQueueTaskProvider.getRunnableTask()
public void registerPendingOperationType(java.lang.String type, IPendingOperationExecutor pox)
type
- pox
- public IPendingOperationExecutor findExecutor(PendingOperation po)
po
-
public void saveOperation(PendingOperation po, StringInputStream sis) throws java.lang.Exception
po
- sis
-
java.lang.Exception
public void saveOperation(PendingOperation po, java.io.Serializable object) throws java.lang.Exception
po
- sis
-
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |