org.jacorb.notification.engine
Class AbstractDeliverTask
- Configurable, Runnable, Disposable
public abstract class AbstractDeliverTask
Version:
- Alphonse Bendt
checkInterrupt , copyMessage , doWork , getTaskExecutor , getTaskProcessor , removeMessage , reset , run , schedule , schedule , schedule , setMessage , setTaskExecutor |
AbstractDeliverTask
protected AbstractDeliverTask(TaskProcessor tp)
getTaskExecutor
protected TaskExecutor getTaskExecutor()
override to use the TaskExecutor provided by the current MessageConsumer
- getTaskExecutor in interface AbstractTask
handleTaskError
public void handleTaskError(AbstractTask task,
Throwable error)
reset
public void reset()
Reset the Object to an initial state. Subclasses should
override this method appropiately to reset the instance to an
initial state.
- reset in interface AbstractTask
schedule
public void schedule()
throws InterruptedException
- schedule in interface AbstractTask
schedule
protected void schedule(boolean directRunAllowed)
throws InterruptedException
override default schedule to use the TaskExecutor provided
by the current MessageConsumer.
- schedule in interface AbstractTask
scheduleTasks
public static void scheduleTasks(AbstractDeliverTask tasks)
throws InterruptedException
setMessageConsumer
public void setMessageConsumer(MessageConsumer messageConsumer)