protected class ContinuousQueryCache.EventRouter<K,V> extends MultiplexingMapListener<K,V>
Base.LoggingWriter, Base.StackFrame
Constructor and Description |
---|
EventRouter(MapListener<? super K,? super V> listener)
Construct an EventRouter to route events from the internal cache of the ContinuousQueryCache to the client listeners.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o)
Compare the EventRouter with another object to determine equality.
|
int |
hashCode()
Determine a hash value for the EventRouter object according to the general
Object.hashCode() contract. |
protected void |
onMapEvent(MapEvent<K,V> evt)
Invoked when a map entry has been inserted, updated or deleted.
|
String |
toString()
Produce a human-readable description of this EventRouter.
|
entryDeleted, entryInserted, entryUpdated
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
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
synchronous
public EventRouter(MapListener<? super K,? super V> listener)
listener
- a client listenerprotected void onMapEvent(MapEvent<K,V> evt)
MapEvent.getId()
.onMapEvent
in class MultiplexingMapListener<K,V>
evt
- the MapEvent carrying the insert, update or delete informationpublic int hashCode()
Object.hashCode()
contract.public boolean equals(Object o)