org.jacorb.notification.engine
Class AbstractDeliverTask
java.lang.Object
org.jacorb.notification.interfaces.AbstractPoolable
org.jacorb.notification.engine.AbstractTask
org.jacorb.notification.engine.AbstractDeliverTask
- All Implemented Interfaces:
- org.apache.avalon.framework.configuration.Configurable, Disposable, java.lang.Runnable
- Direct Known Subclasses:
- PushToConsumerTask, TimerDeliverTask
- public abstract class AbstractDeliverTask
- extends AbstractTask
- Version:
- $Id: AbstractDeliverTask.java,v 1.10 2004/05/06 12:39:59 nicolas Exp $
- Author:
- Alphonse Bendt
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AbstractDeliverTask
protected AbstractDeliverTask(TaskProcessor tp)
scheduleTasks
public static void scheduleTasks(AbstractDeliverTask[] tasks)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
reset
public void reset()
- Description copied from class:
AbstractPoolable
- Reset the Object to an initial state. Subclasses should
override this method appropiately to reset the instance to an
initial state.
- Overrides:
reset
in class AbstractTask
getMessageConsumer
protected MessageConsumer getMessageConsumer()
setMessageConsumer
public void setMessageConsumer(MessageConsumer messageConsumer)
handleTaskError
public void handleTaskError(AbstractTask task,
java.lang.Throwable error)
schedule
protected void schedule(boolean directRunAllowed)
throws java.lang.InterruptedException
- override default schedule to use the TaskExecutor provided
by the current MessageConsumer.
- Overrides:
schedule
in class AbstractTask
- Parameters:
directRunAllowed
- this param specified if its allowed to
run this Task on the calling Thread.
- Throws:
java.lang.InterruptedException
schedule
public void schedule()
throws java.lang.InterruptedException
- Specified by:
schedule
in class AbstractTask
- Throws:
java.lang.InterruptedException
getTaskExecutor
protected TaskExecutor getTaskExecutor()
- override to use the TaskExecutor provided by the current MessageConsumer
- Overrides:
getTaskExecutor
in class AbstractTask