org.jacorb.notification.engine
Class PullFromSupplierTask

java.lang.Object
  extended byorg.jacorb.notification.interfaces.AbstractPoolable
      extended byorg.jacorb.notification.engine.AbstractTask
          extended byorg.jacorb.notification.engine.PullFromSupplierTask
All Implemented Interfaces:
org.apache.avalon.framework.configuration.Configurable, Disposable, java.lang.Runnable

public class PullFromSupplierTask
extends AbstractTask

Version:
$Id: PullFromSupplierTask.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_
 
Method Summary
 void doWork()
          Override this Method in Subclasses to do the "real work".
 void handleTaskError(AbstractTask task, java.lang.Throwable 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, copyMessage, getTaskExecutor, getTaskProcessor, removeMessage, run, schedule, schedule, setMessage, setTaskExecutor
 
Methods inherited from class org.jacorb.notification.interfaces.AbstractPoolable
configure, 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.

Overrides:
reset in class AbstractTask

handleTaskError

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

schedule

public void schedule()
              throws java.lang.InterruptedException
Specified by:
schedule in class AbstractTask
Throws:
java.lang.InterruptedException