|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.interfaces.AbstractPoolable
org.jacorb.notification.engine.AbstractTask
Field Summary | |
protected Message |
message_
|
Fields inherited from class org.jacorb.notification.interfaces.AbstractPoolable |
logger_ |
Constructor Summary | |
protected |
AbstractTask(TaskProcessor tp)
|
Method Summary | |
protected void |
checkInterrupt()
|
Message |
copyMessage()
|
abstract void |
doWork()
Override this Method in Subclasses to do the "real work". |
protected TaskExecutor |
getTaskExecutor()
|
protected TaskProcessor |
getTaskProcessor()
|
Message |
removeMessage()
|
void |
reset()
Reset the Object to an initial state. |
void |
run()
template method. |
abstract void |
schedule()
|
protected void |
schedule(boolean directRunAllowed)
Run this Task on its configured Executor. |
protected void |
schedule(TaskExecutor executor,
boolean directRunAllowed)
Run this Task on the provided Executor. |
void |
setMessage(Message event)
set the Message for this Task to use. |
protected void |
setTaskExecutor(TaskExecutor taskExecutor)
|
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 |
Field Detail |
protected Message message_
Constructor Detail |
protected AbstractTask(TaskProcessor tp)
Method Detail |
protected TaskExecutor getTaskExecutor()
protected void setTaskExecutor(TaskExecutor taskExecutor)
protected TaskProcessor getTaskProcessor()
public void setMessage(Message event)
public Message removeMessage()
public Message copyMessage()
public abstract void doWork() throws java.lang.Exception
java.lang.Exception
public void run()
run
in interface java.lang.Runnable
public void reset()
AbstractPoolable
reset
in class AbstractPoolable
protected void checkInterrupt() throws java.lang.InterruptedException
java.lang.InterruptedException
protected void schedule(boolean directRunAllowed) throws java.lang.InterruptedException
directRunAllowed
- this param specified if its allowed to
run this Task on the calling Thread.
InterruptedException
- if an error occursprotected void schedule(TaskExecutor executor, boolean directRunAllowed) throws java.lang.InterruptedException
executor
- a TaskExecutor
valuedirectRunAllowed
- a boolean
value
InterruptedException
- if an error occurspublic abstract void schedule() throws java.lang.InterruptedException
java.lang.InterruptedException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |