Package com.tangosol.coherence.commonj

Class WorkManager.WorkObserver

java.lang.Object

com.tangosol.util.Base

com.tangosol.coherence.commonj.WorkManager.WorkObserver

All Implemented Interfaces:

InvocationObserver

Enclosing class:

WorkManager

protected class WorkManager.WorkObserver
extends Base
implements InvocationObserver

The InvocationObserver for all posted work. It serves only to update the work status from "none" to WORK_ACCEPTED or WORK_REJECTED. The completion is sent back as a separate communication using a SendFeedback agent.

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.util.Base

LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WorkObserver()

Method Summary

Modifier and Type	Method	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).

Methods inherited from class com.tangosol.util.Base

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, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, 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, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkObserver

protected WorkObserver()

Method Detail

memberCompleted

public void memberCompleted(Member member,
                            Object oResult)

This method is called when a Member has finished running the ScheduleWork agent.

Specified by:

memberCompleted in interface InvocationObserver

Parameters:

member - cluster Member that has finished the execution of the ScheduleWork agent

oResult - the result, if any, of the invocation

memberFailed

public void memberFailed(Member member,
                         Throwable eFailure)

This method is called when a Member has thrown an exception while running the Invocable object.

Specified by:

memberFailed in interface InvocationObserver

Parameters:

member - cluster Member that encountered an exception while executing the Invocable object

eFailure - the Throwable object that was encountered

memberLeft

public 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).

Specified by:

memberLeft in interface InvocationObserver

Parameters:

member - cluster Member that left the service before reporting the completion of the execution of the Invocable object

invocationCompleted

public 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.

Specified by:

invocationCompleted in interface InvocationObserver