org.jacorb.notification.engine
Class PullFromSupplierTask

java.lang.Object
  org.jacorb.notification.util.AbstractPoolable
      org.jacorb.notification.engine.AbstractTask
          org.jacorb.notification.engine.PullFromSupplierTask

All Implemented Interfaces:

Disposable, org.picocontainer.Disposable, java.lang.Runnable, Schedulable

public class PullFromSupplierTask

extends AbstractTask

Version:

$Id: PullFromSupplierTask.java,v 1.16 2005/10/02 15:18:39 alphonse.bendt Exp $

Author:

Alphonse Bendt

Field Summary

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

logger_

Method Summary

void	doWork() Override this Method in Subclasses to do the "real work".
void	handleTaskError(AbstractTask task, java.lang.Exception error)
void	reset() Reset the Object to an initial state.
void	schedule()
void	setTarget(MessageSupplier target)

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

checkInterrupt, getTaskExecutor, isRunnable, run, schedule, schedule, setTaskExecutor

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

dispose, setObjectPool

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

setTarget

public void setTarget(MessageSupplier target)

doWork

public void doWork()
            throws Disconnected

Description copied from class: AbstractTask

Override this Method in Subclasses to do the "real work".

Specified by:

doWork in class AbstractTask

Throws:

Disconnected

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.

Specified by:

reset in class AbstractPoolable

handleTaskError

public void handleTaskError(AbstractTask task,
                            java.lang.Exception error)

Parameters:

task - the task that caused the error.

error - the exception that was thrown.

schedule

public void schedule()