org.jacorb.notification.engine

Interface TaskProcessor

public interface TaskProcessor

Version: $Id: TaskProcessor.java,v 1.29 2006/07/07 12:38:44 alphonse.bendt Exp $

Author: Alphonse Bendt

Method Summary
ScheduledFutureexecuteTaskAfterDelay(long delay, Runnable task)
ScheduledFutureexecuteTaskPeriodically(long intervall, Runnable task, boolean startImmediately)
TaskFactorygetTaskFactory()
voidprocessMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied.
voidscheduleTimedPullTask(MessageSupplier dest)
Schedule ProxyPullConsumer for pull-Operation.

Method Detail

executeTaskAfterDelay

public ScheduledFuture executeTaskAfterDelay(long delay, Runnable task)

executeTaskPeriodically

public ScheduledFuture executeTaskPeriodically(long intervall, Runnable task, boolean startImmediately)

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)
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