|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.engine.DefaultTaskProcessor
Constructor Summary | |
---|---|
DefaultTaskProcessor(org.apache.avalon.framework.configuration.Configuration config)
Start ClockDaemon Set up TaskExecutors Set up TaskFactory |
Method Summary | |
---|---|
void |
cancelTask(java.lang.Object id)
|
void |
dispose()
shutdown this TaskProcessor. |
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. |
protected void |
processMessageInternal(Message event)
process a Message. create FilterTask and schedule it. |
void |
schedulePushOperation(IProxyPushSupplier pushSupplier)
Schedule MessageConsumer for a deliver-Operation. |
void |
scheduleTimedPullTask(MessageSupplier messageSupplier)
Schedule ProxyPullConsumer for pull-Operation. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public DefaultTaskProcessor(org.apache.avalon.framework.configuration.Configuration config)
Method Detail |
public TaskFactory getTaskFactory()
getTaskFactory
in interface TaskProcessor
public TaskExecutor getFilterTaskExecutor()
getFilterTaskExecutor
in interface TaskProcessor
public void dispose()
dispose
in interface org.picocontainer.Disposable
public void processMessage(Message mesg)
processMessage
in interface TaskProcessor
protected void processMessageInternal(Message event)
public void scheduleTimedPullTask(MessageSupplier messageSupplier) throws java.lang.InterruptedException
scheduleTimedPullTask
in interface TaskProcessor
java.lang.InterruptedException
public void schedulePushOperation(IProxyPushSupplier pushSupplier) throws java.lang.InterruptedException
schedulePushOperation
in interface TaskProcessor
java.lang.InterruptedException
public java.lang.Object executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
executeTaskPeriodically
in interface TaskProcessor
public void cancelTask(java.lang.Object id)
cancelTask
in interface TaskProcessor
public java.lang.Object executeTaskAfterDelay(long delay, java.lang.Runnable task)
executeTaskAfterDelay
in interface TaskProcessor
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |