Class AfterInsertProcessor<K>

  • All Implemented Interfaces:
    com.tangosol.util.InvocableMap.EntryProcessor<K,​CoherenceRegionValue,​Boolean>, Serializable

    public class AfterInsertProcessor<K>
    extends com.tangosol.util.processor.AbstractProcessor<K,​CoherenceRegionValue,​Boolean>
    implements Serializable
    A AbstractReadWriteCoherenceEntityDataAccess.AfterInsertProcessor is an EntryProcessor responsible for inserting a value into cache if none is present, and returning a boolean indicating whether it did so, consistent with the expected behavior of a read-write cache access strategy's afterInsert() method. We move this behavior into the grid for efficient concurrency control.
    Author:
    Randy Stafford, Gunnar Hillert
    See Also:
    Serialized Form
    • Nested Class Summary

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

        com.tangosol.util.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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Boolean process​(com.tangosol.util.InvocableMap.Entry entry)
      • 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, 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
    • Constructor Detail

      • AfterInsertProcessor

        public AfterInsertProcessor​(CoherenceRegionValue cacheValue)
        Complete constructor.
        Parameters:
        cacheValue - the cache value for use by this AfterInsertProcessor
    • Method Detail

      • process

        public Boolean process​(com.tangosol.util.InvocableMap.Entry entry)
        Specified by:
        process in interface com.tangosol.util.InvocableMap.EntryProcessor<K,​CoherenceRegionValue,​Boolean>