Package com.tangosol.net.cache

Class ReadWriteBackingMap.InternalMapListener

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.ReadWriteBackingMap.InternalMapListener

All Implemented Interfaces:

MapListener, EventListener

Direct Known Subclasses:

VersionedBackingMap.InternalMapListener

Enclosing class:

ReadWriteBackingMap

protected class ReadWriteBackingMap.InternalMapListener
extends Base
implements MapListener

A MapListener implementation that listens to the internal cache and routes those events to anyone listening to this ReadWriteBackingMap.

Author:

cp 2002.10.22

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

Fields inherited from interface com.tangosol.util.MapListener

ASYNCHRONOUS, SYNCHRONOUS, VERSION_AWARE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InternalMapListener()

Method Summary

Modifier and Type	Method	Description
protected void	dispatch(MapEvent evt)	Dispatch the event to the corresponding listeners.
void	entryDeleted(MapEvent evt)	Invoked when a map entry has been removed.
void	entryInserted(MapEvent evt)	Invoked when a map entry has been inserted.
void	entryUpdated(MapEvent evt)	Invoked when a map entry has been updated.
protected void	processDeletedEntry(Object oKey, Object oValueOld)	Process an entry that is about to be removed from the internal cache.

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

Methods inherited from interface com.tangosol.util.MapListener

characteristics, isAsynchronous, isSynchronous, isVersionAware, synchronous

Constructor Detail

InternalMapListener

protected InternalMapListener()

Method Detail

entryInserted

public void entryInserted(MapEvent evt)

Invoked when a map entry has been inserted.

Specified by:

entryInserted in interface MapListener

Parameters:

evt - the MapEvent carrying the insert information

entryUpdated

public void entryUpdated(MapEvent evt)

Invoked when a map entry has been updated.

Specified by:

entryUpdated in interface MapListener

Parameters:

evt - the MapEvent carrying the update information

entryDeleted

public void entryDeleted(MapEvent evt)

Invoked when a map entry has been removed.

Specified by:

entryDeleted in interface MapListener

Parameters:

evt - the MapEvent carrying the delete information

processDeletedEntry

protected void processDeletedEntry(Object oKey,
                                   Object oValueOld)

Process an entry that is about to be removed from the internal cache. This method is called after the entry has been successfully locked, but before any listeners are notified.

If the entry is queued to be inserted or updated, then that must occur (be persisted) before we notify any listeners that it has been removed from the internal cache, otherwise (for example) if this server dies and it has the only copy of the pending update then the update will be lost!

Parameters:

oKey - the key

oValueOld - the old value

dispatch

protected void dispatch(MapEvent evt)

Dispatch the event to the corresponding listeners.

Parameters:

evt - the MapEvent object