public interface QueueListener
QueueListener
provides queue management information to external entities:
QueueService
they'll observe.Modifier and Type | Method and Description |
---|---|
void |
enlisted(JobInfo info)
Invoked when a job is just being enlisted (before processing).
|
void |
executed(JobInfo info,
java.lang.Object result)
Invoked when a job's execution is finished successfully.
|
void |
failed(JobInfo info,
java.lang.Throwable throwable)
Invoked when a job's execution is finished with error.
|
void |
started(JobInfo info)
Invoked when a job's execution is just about to be started.
|
void enlisted(JobInfo info)
JobInfo.getEnlistmentTime()
and JobInfo.getWaitDuration()
provides meaningful values.
Note that waitDuration
value is re-evaluated at each call.info
- The job being enlistedvoid started(JobInfo info)
JobInfo.getEnlistmentTime()
, JobInfo.getWaitDuration()
, JobInfo.getStartTime()
and JobInfo.getExecutionDuration()
provides meaningful values.
Note that executionDuration
value is re-evaluated at each call.info
- The job being startedvoid executed(JobInfo info, java.lang.Object result)
result
(memory leak).info
- The executed jobresult
- The job's resultvoid failed(JobInfo info, java.lang.Throwable throwable)
throwable
(memory leak).info
- The failed jobthrowable
- The job's thrown exceptionCopyright © 2006-2014 The Apache Software Foundation. All Rights Reserved.