Package com.oracle.coherence.concurrent.executor

Class ClusteredTaskManager.NotifyExecutionStrategyProcessor

java.lang.Object

com.tangosol.util.Base

com.tangosol.util.processor.AbstractProcessor<String,ClusteredTaskManager,Boolean>

com.oracle.coherence.concurrent.executor.PortableAbstractProcessor<String,ClusteredTaskManager,Boolean>

com.oracle.coherence.concurrent.executor.ClusteredTaskManager.NotifyExecutionStrategyProcessor

All Implemented Interfaces:

PortableObject, InvocableMap.EntryProcessor<String,ClusteredTaskManager,Boolean>, Serializable

Enclosing class:

ClusteredTaskManager<T,A,R>

public static class ClusteredTaskManager.NotifyExecutionStrategyProcessor
extends PortableAbstractProcessor<String,ClusteredTaskManager,Boolean>

An InvocableMap.EntryProcessor to notify the Task that an event has occurred which requires the ExecutionStrategy to be re-evaluated.

See Also:

• Serialized Form

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

DEFAULT_LOAD_FACTOR, 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

Constructor	Description
NotifyExecutionStrategyProcessor()	Constructs ClusteredTaskManager.NotifyExecutionStrategyProcessor.

Method Summary

Modifier and Type	Method	Description
Boolean	process(InvocableMap.Entry<String,ClusteredTaskManager> entry)	Process a Map.Entry object.

Methods inherited from class com.oracle.coherence.concurrent.executor.PortableAbstractProcessor

readExternal, writeExternal

Methods inherited from class com.tangosol.util.processor.AbstractProcessor

processAll

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, newHashMap, newHashMap, newHashSet, newHashSet, 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 Details

NotifyExecutionStrategyProcessor

public NotifyExecutionStrategyProcessor()

Constructs ClusteredTaskManager.NotifyExecutionStrategyProcessor.

Method Details

process

public Boolean process(InvocableMap.Entry<String,ClusteredTaskManager> entry)

Description copied from interface: InvocableMap.EntryProcessor

Process a Map.Entry object.

Note: if this method throws an exception, all modifications to the supplied entry or any other entries retrieved via the BackingMapContext.getBackingMapEntry(java.lang.Object) API will be rolled back leaving all underlying values unchanged.

Parameters:

entry - the Entry to process

Returns:

the result of the processing, if any