org.jacorb.notification.engine
Interface TaskProcessor
- All Known Implementing Classes:
- DefaultTaskProcessor
- public interface TaskProcessor
- Version:
- $Id: TaskProcessor.java,v 1.28 2005/11/11 19:37:44 alphonse.bendt Exp $
- Author:
- Alphonse Bendt
getTaskFactory
public TaskFactory getTaskFactory()
processMessage
public void processMessage(Message mesg)
- process a Message. the various settings for the Message
(timeout, starttime, stoptime) are checked and applied.
scheduleTimedPullTask
public void scheduleTimedPullTask(MessageSupplier dest)
throws java.lang.InterruptedException
- 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
- Throws:
java.lang.InterruptedException
executeTaskPeriodically
public edu.emory.mathcs.backport.java.util.concurrent.ScheduledFuture executeTaskPeriodically(long intervall,
java.lang.Runnable task,
boolean startImmediately)
executeTaskAfterDelay
public edu.emory.mathcs.backport.java.util.concurrent.ScheduledFuture executeTaskAfterDelay(long delay,
java.lang.Runnable task)