org.jacorb.notification.engine
Interface TaskProcessor
- All Known Implementing Classes:
- DefaultTaskProcessor
public interface TaskProcessor
- Version:
- $Id: TaskProcessor.java,v 1.29 2006/07/07 12:38:44 alphonse.bendt Exp $
- Author:
- Alphonse Bendt
getTaskFactory
TaskFactory getTaskFactory()
processMessage
void processMessage(Message mesg)
- process a Message. the various settings for the Message
(timeout, starttime, stoptime) are checked and applied.
scheduleTimedPullTask
void scheduleTimedPullTask(MessageSupplier dest)
- Schedule ProxyPullConsumer for pull-Operation.
If a Supplier connects to a ProxyPullConsumer the
ProxyPullConsumer needs to regularely poll the Supplier.
This method queues a Task to run runPullEvent on the specified
TimerEventSupplier
executeTaskPeriodically
java.util.concurrent.ScheduledFuture executeTaskPeriodically(long intervall,
java.lang.Runnable task,
boolean startImmediately)
executeTaskAfterDelay
java.util.concurrent.ScheduledFuture executeTaskAfterDelay(long delay,
java.lang.Runnable task)