|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.engine.TaskProcessor
Constructor Summary | |
TaskProcessor()
Start ClockDaemon Set up TaskExecutors Set up TaskFactory |
Method Summary | |
void |
cancelTask(java.lang.Object id)
|
void |
configure(org.apache.avalon.framework.configuration.Configuration conf)
|
void |
configureTaskExecutor(AbstractProxySupplier proxySupplier)
configure a AbstractProxySupplier to use a TaskExecutor dependent on the settings for the current Channel. |
void |
dispose()
shutdown this TaskProcessor. |
java.lang.Object |
executeTaskPeriodically(long intervall,
java.lang.Runnable task,
boolean startImmediately)
|
long |
getBackoutInterval()
|
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 |
scheduleTimedPullTask(MessageSupplier dest)
Schedule ProxyPullConsumer for pull-Operation. |
void |
scheduleTimedPushTask(MessageConsumer consumer)
Schedule MessageConsumer for a deliver-Operation. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TaskProcessor()
Method Detail |
public void configure(org.apache.avalon.framework.configuration.Configuration conf)
configure
in interface org.apache.avalon.framework.configuration.Configurable
public TaskFactory getTaskFactory()
public long getBackoutInterval()
public void configureTaskExecutor(AbstractProxySupplier proxySupplier)
public void dispose()
dispose
in interface Disposable
public void processMessage(Message mesg)
protected void processMessageInternal(Message event)
public void scheduleTimedPullTask(MessageSupplier dest) throws java.lang.InterruptedException
java.lang.InterruptedException
public void scheduleTimedPushTask(MessageConsumer 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)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |