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

Method Summary
 java.util.concurrent.ScheduledFuture executeTaskAfterDelay(long delay, java.lang.Runnable task)
           
 java.util.concurrent.ScheduledFuture executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
           
 TaskFactory getTaskFactory()
           
 void processMessage(Message mesg)
          process a Message.
 void scheduleTimedPullTask(MessageSupplier dest)
          Schedule ProxyPullConsumer for pull-Operation.
 

Method Detail

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)