org.jacorb.notification.engine

Class AbstractDeliverTask

Implemented Interfaces:
Configurable, Runnable, Disposable
Known Direct 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

Field Summary

Fields inherited from class org.jacorb.notification.engine.AbstractTask

message_

Fields inherited from class org.jacorb.notification.interfaces.AbstractPoolable

logger_

Constructor Summary

AbstractDeliverTask(TaskProcessor tp)

Method Summary

protected MessageConsumer
getMessageConsumer()
protected TaskExecutor
getTaskExecutor()
override to use the TaskExecutor provided by the current MessageConsumer
void
handleTaskError(AbstractTask task, Throwable error)
void
reset()
Reset the Object to an initial state.
void
schedule()
protected void
schedule(boolean directRunAllowed)
override default schedule to use the TaskExecutor provided by the current MessageConsumer.
static void
scheduleTasks(AbstractDeliverTask tasks)
void
setMessageConsumer(MessageConsumer messageConsumer)

Methods inherited from class org.jacorb.notification.engine.AbstractTask

checkInterrupt, copyMessage, doWork, getTaskExecutor, getTaskProcessor, removeMessage, reset, run, schedule, schedule, schedule, setMessage, setTaskExecutor

Methods inherited from class org.jacorb.notification.interfaces.AbstractPoolable

configure, dispose, reset, setObjectPool

Constructor Details

AbstractDeliverTask

protected AbstractDeliverTask(TaskProcessor tp)

Method Details

getMessageConsumer

protected MessageConsumer getMessageConsumer()


getTaskExecutor

protected TaskExecutor getTaskExecutor()
override to use the TaskExecutor provided by the current MessageConsumer
Overrides:
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.
Overrides:
reset in interface AbstractTask


schedule

public void schedule()
            throws InterruptedException
Overrides:
schedule in interface AbstractTask


schedule

protected void schedule(boolean directRunAllowed)
            throws InterruptedException
override default schedule to use the TaskExecutor provided by the current MessageConsumer.
Overrides:
schedule in interface AbstractTask


scheduleTasks

public static void scheduleTasks(AbstractDeliverTask tasks)
            throws InterruptedException


setMessageConsumer

public void setMessageConsumer(MessageConsumer messageConsumer)