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

Method Summary
 edu.emory.mathcs.backport.java.util.concurrent.ScheduledFuture executeTaskAfterDelay(long delay, java.lang.Runnable task)
           
 edu.emory.mathcs.backport.java.util.concurrent.ScheduledFuture executeTaskPeriodically(long intervall, java.lang.Runnable task, boolean startImmediately)
           
 TaskFactory getTaskFactory()
           
 void processMessage(Message mesg)
          process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied.
 void scheduleTimedPullTask(MessageSupplier dest)
          Schedule ProxyPullConsumer for pull-Operation.
 

Method Detail

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)