|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.work.WorkerContext
Work wrapper providing an execution context to a Work instance.
Constructor Summary | |
WorkerContext(Work aWork)
Create a WorkWrapper. |
|
WorkerContext(Work aWork,
long aStartTimeout,
ExecutionContext execContext,
XAWork xaWork,
WorkListener workListener)
Create a WorkWrapper with the specified execution context. |
Method Summary | |
long |
getAcceptedTime()
System.currentTimeMillis() when the Work has been accepted. |
long |
getStartTimeout()
Gets the time duration (in milliseconds) within which the execution of the Work instance must start. |
int |
getThreadPriority()
Gets the priority level of the thread, which will be dispatched to process this work. |
WorkException |
getWorkException()
Gets the WorkException, if any, thrown during the execution. |
boolean |
isTimedOut()
Used by a Work executor in order to know if this work, which should be accepted but not started has timed out. |
Latch |
provideEndLatch()
Provides a latch, which can be used to wait the end of a work execution. |
Latch |
provideStartLatch()
Provides a latch, which can be used to wait the start of a work execution. |
void |
release()
|
void |
run()
|
void |
setThreadPriority(int aPriority)
Defines the thread priority level of the thread, which will be dispatched to process this work. |
String |
toString()
|
void |
workAccepted(Object anObject)
Call-back method used by a Work executor in order to notify this instance that the wrapped Work instance has been accepted. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public WorkerContext(Work aWork)
aWork
- Work to be wrapped.public WorkerContext(Work aWork, long aStartTimeout, ExecutionContext execContext, XAWork xaWork, WorkListener workListener)
aWork
- Work to be wrapped.aStartTimeout
- a time duration (in milliseconds) within which the
execution of the Work instance must start.execContext
- an object containing the execution context with which
the submitted Work instance must be executed.workListener
- an object which would be notified when the various
Work processing events (work accepted, work rejected, work started,
work completed) occur.Method Detail |
public void release()
release
in interface Work
public void setThreadPriority(int aPriority)
aPriority
- Priority of the thread to be used to process the wrapped
Work instance.public int getThreadPriority()
public void workAccepted(Object anObject)
anObject
- Object on which the event initially occurred. It should
be the work executor.public long getAcceptedTime()
public long getStartTimeout()
public boolean isTimedOut()
public WorkException getWorkException()
public void run()
run
in interface Runnable
public Latch provideStartLatch()
public Latch provideEndLatch()
public String toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |