org.cometd.oort

Class OortMap.DeltaListener<K,V>

java.lang.Object

org.cometd.oort.OortMap.DeltaListener<K,V>

Type Parameters:

K - the key type

V - the value type

All Implemented Interfaces:

EventListener, OortObject.Listener<ConcurrentMap<K,V>>

Enclosing class:

OortMap<K,V>

public static class OortMap.DeltaListener<K,V>
extends Object
implements OortObject.Listener<ConcurrentMap<K,V>>

An implementation of Listener that converts whole map events into OortMap.EntryListener events.

For example, if an entity map:

 {
     key0: value0,
     key1: value1,
     key2: value2
 }
 

is replaced by a map:

 {
     key0: value0,
     key1: valueA,
     key3: valueB
 }
 

then this listener generates two "put" events with the following entries:

 (key1, value1, valueA)
 (key3, null, valueB)
 

and one "remove" event with the following entry:

 (key2, value2, null)
 

Note that no event is emitted for key0; the values for key0 of the two maps are tested via Object.equals(Object) and if they are equal no event is generated.

Constructor Summary

Constructors

Constructor and Description
DeltaListener(OortMap<K,V> oortMap)

Method Summary

Modifier and Type	Method and Description
void	onRemoved(OortObject.Info<ConcurrentMap<K,V>> info) Callback method invoked when the object value is removed, for example because the correspondent node has been shut down or crashed.
void	onUpdated(OortObject.Info<ConcurrentMap<K,V>> oldInfo, OortObject.Info<ConcurrentMap<K,V>> newInfo) Callback method invoked when the object value is updated.

Methods inherited from class java.lang.Object

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

Constructor Detail

DeltaListener

public DeltaListener(OortMap<K,V> oortMap)

Method Detail

onUpdated

public void onUpdated(OortObject.Info<ConcurrentMap<K,V>> oldInfo,
                      OortObject.Info<ConcurrentMap<K,V>> newInfo)

Description copied from interface: OortObject.Listener

Callback method invoked when the object value is updated.

Specified by:

onUpdated in interface OortObject.Listener<ConcurrentMap<K,V>>

Parameters:

oldInfo - the OortObject.Info before the change, may be null

newInfo - the OortObject.Info after the change

onRemoved

public void onRemoved(OortObject.Info<ConcurrentMap<K,V>> info)

Description copied from interface: OortObject.Listener

Callback method invoked when the object value is removed, for example because the correspondent node has been shut down or crashed.

Specified by:

onRemoved in interface OortObject.Listener<ConcurrentMap<K,V>>

Parameters:

info - the OortObject.Info before the removal