protected class WorkManager.WorkObserver extends Base implements InvocationObserver
Base.LoggingWriter, Base.StackFrame
Modifier | Constructor and Description |
---|---|
protected |
WorkObserver() |
Modifier and Type | Method and Description |
---|---|
void |
invocationCompleted()
This method is called when all service members have either finished the Invocable object execution or are not (or no longer) running the InvocationService.
|
void |
memberCompleted(Member member, Object oResult)
This method is called when a Member has finished running the ScheduleWork agent.
|
void |
memberFailed(Member member, Throwable eFailure)
This method is called when a Member has thrown an exception while running the Invocable object.
|
void |
memberLeft(Member member)
This method is called when a Member that the Invocable} object was intended for execution upon has left the service (or the cluster).
|
azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait
public void memberCompleted(Member member, Object oResult)
memberCompleted
in interface InvocationObserver
member
- cluster Member that has finished the execution of the ScheduleWork agentoResult
- the result, if any, of the invocationpublic void memberFailed(Member member, Throwable eFailure)
memberFailed
in interface InvocationObserver
member
- cluster Member that encountered an exception while executing the Invocable objecteFailure
- the Throwable object that was encounteredpublic void memberLeft(Member member)
memberLeft
in interface InvocationObserver
member
- cluster Member that left the service before reporting the completion of the execution of the Invocable objectpublic void invocationCompleted()
invocationCompleted
in interface InvocationObserver