|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Method Summary | |
---|---|
void |
cancelTask(java.lang.Object id)
|
java.lang.Object |
executeTaskAfterDelay(long delay,
java.lang.Runnable task)
|
java.lang.Object |
executeTaskPeriodically(long intervall,
java.lang.Runnable task,
boolean startImmediately)
|
TaskExecutor |
getFilterTaskExecutor()
|
TaskFactory |
getTaskFactory()
|
void |
processMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied. |
void |
schedulePushOperation(IProxyPushSupplier consumer)
Schedule MessageConsumer for a deliver-Operation. |
void |
scheduleTimedPullTask(MessageSupplier dest)
Schedule ProxyPullConsumer for pull-Operation. |
Method Detail |
public TaskFactory getTaskFactory()
public TaskExecutor getFilterTaskExecutor()
public void processMessage(Message mesg)
public void scheduleTimedPullTask(MessageSupplier dest) throws java.lang.InterruptedException
java.lang.InterruptedException
public void schedulePushOperation(IProxyPushSupplier consumer) throws java.lang.InterruptedException
java.lang.InterruptedException
public java.lang.Object executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
public void cancelTask(java.lang.Object id)
public java.lang.Object executeTaskAfterDelay(long delay, java.lang.Runnable task)
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |