org.kaazing.gateway.server.util.collection

Class ReplicatedIMap<K,V>

java.lang.Object

org.kaazing.gateway.server.util.collection.MapProxy<K,V>

org.kaazing.gateway.server.util.collection.ConcurrentMapProxy<K,V>

org.kaazing.gateway.server.util.collection.IMapProxy<K,V>

org.kaazing.gateway.server.util.collection.ReplicatedIMap<K,V>

All Implemented Interfaces:

com.hazelcast.core.IMap<K,V>, com.hazelcast.core.Instance, Serializable, ConcurrentMap<K,V>, Map<K,V>

public class ReplicatedIMap<K,V>
extends IMapProxy<K,V>
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Nested classes/interfaces inherited from interface com.hazelcast.core.Instance

com.hazelcast.core.Instance.InstanceType

Constructor Summary

Constructors

Constructor and Description
ReplicatedIMap(com.hazelcast.core.IMap<K,V> delegate)

Method Summary

Modifier and Type	Method and Description
void	addEntryListener(com.hazelcast.core.EntryListener<K,V> listener, boolean includeValue)
void	addEntryListener(com.hazelcast.core.EntryListener<K,V> listener, K key, boolean includeValue)
void	addIndex(com.hazelcast.query.Expression<?> arg0, boolean arg1)
void	addIndex(String attribute, boolean ordered)
void	addLocalEntryListener(com.hazelcast.core.EntryListener<K,V> arg0)
Set<Map.Entry<K,V>>	entrySet()
Set<Map.Entry<K,V>>	entrySet(com.hazelcast.query.Predicate predicate)
boolean	evict(Object key)
void	flush()
V	get(Object key)
Map<K,V>	getAll(Set<K> arg0)
Future<V>	getAsync(K key)
protected com.hazelcast.core.IMap<K,V>	getDelegate()
com.hazelcast.monitor.LocalMapStats	getLocalMapStats()
Set<K>	keySet()
Set<K>	keySet(com.hazelcast.query.Predicate predicate)
Set<K>	localKeySet()
Set<K>	localKeySet(com.hazelcast.query.Predicate predicate)
boolean	lockMap(long time, TimeUnit timeunit)
V	put(K key, V value, long ttl, TimeUnit timeunit)
void	putAndUnlock(K arg0, V arg1)
Future<V>	putAsync(K key, V value)
V	putIfAbsent(K key, V value)
V	putIfAbsent(K key, V value, long ttl, TimeUnit timeunit)
void	putTransient(K arg0, V arg1, long arg2, TimeUnit arg3)
Future<V>	removeAsync(K arg0)
void	removeEntryListener(com.hazelcast.core.EntryListener<K,V> listener)
void	removeEntryListener(com.hazelcast.core.EntryListener<K,V> listener, K key)
String	toString()
V	tryLockAndGet(K arg0, long arg1, TimeUnit arg2)
boolean	tryPut(K key, V value, long timeout, TimeUnit timeunit)
Object	tryRemove(K arg0, long arg1, TimeUnit arg2)
void	unlockMap()
Collection<V>	values()
Collection<V>	values(com.hazelcast.query.Predicate predicate)

Methods inherited from class org.kaazing.gateway.server.util.collection.IMapProxy

destroy, getId, getInstanceType, getMapEntry, getName, lock, tryLock, tryLock, unlock

Methods inherited from class org.kaazing.gateway.server.util.collection.ConcurrentMapProxy

remove, replace, replace

Methods inherited from class org.kaazing.gateway.server.util.collection.MapProxy

clear, containsKey, containsValue, isEmpty, put, putAll, remove, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, remove, replace, replace, replaceAll

Methods inherited from interface java.util.Map

clear, containsKey, containsValue, equals, hashCode, isEmpty, put, putAll, remove, size

Constructor Detail

ReplicatedIMap

public ReplicatedIMap(com.hazelcast.core.IMap<K,V> delegate)

Method Detail

addEntryListener

public void addEntryListener(com.hazelcast.core.EntryListener<K,V> listener,
                             boolean includeValue)

Specified by:

addEntryListener in interface com.hazelcast.core.IMap<K,V>

Overrides:

addEntryListener in class IMapProxy<K,V>

addEntryListener

public void addEntryListener(com.hazelcast.core.EntryListener<K,V> listener,
                             K key,
                             boolean includeValue)

Specified by:

addEntryListener in interface com.hazelcast.core.IMap<K,V>

Overrides:

addEntryListener in class IMapProxy<K,V>

removeEntryListener

public void removeEntryListener(com.hazelcast.core.EntryListener<K,V> listener,
                                K key)

Specified by:

removeEntryListener in interface com.hazelcast.core.IMap<K,V>

Overrides:

removeEntryListener in class IMapProxy<K,V>

removeEntryListener

public void removeEntryListener(com.hazelcast.core.EntryListener<K,V> listener)

Specified by:

removeEntryListener in interface com.hazelcast.core.IMap<K,V>

Overrides:

removeEntryListener in class IMapProxy<K,V>

putIfAbsent

public V putIfAbsent(K key,
                     V value)

Specified by:

putIfAbsent in interface ConcurrentMap<K,V>

Specified by:

putIfAbsent in interface Map<K,V>

Overrides:

putIfAbsent in class ConcurrentMapProxy<K,V>

get

public V get(Object key)

Specified by:

get in interface Map<K,V>

Overrides:

get in class MapProxy<K,V>

getDelegate

protected com.hazelcast.core.IMap<K,V> getDelegate()

Specified by:

getDelegate in class IMapProxy<K,V>

entrySet

public Set<Map.Entry<K,V>> entrySet()

Specified by:

entrySet in interface Map<K,V>

Overrides:

entrySet in class MapProxy<K,V>

keySet

public Set<K> keySet()

Specified by:

keySet in interface Map<K,V>

Overrides:

keySet in class MapProxy<K,V>

values

public Collection<V> values()

Specified by:

values in interface Map<K,V>

Overrides:

values in class MapProxy<K,V>

toString

public String toString()

Overrides:

toString in class Object

addIndex

public void addIndex(String attribute,
                     boolean ordered)

Specified by:

addIndex in interface com.hazelcast.core.IMap<K,V>

entrySet

public Set<Map.Entry<K,V>> entrySet(com.hazelcast.query.Predicate predicate)

Specified by:

entrySet in interface com.hazelcast.core.IMap<K,V>

evict

public boolean evict(Object key)

Specified by:

evict in interface com.hazelcast.core.IMap<K,V>

getLocalMapStats

public com.hazelcast.monitor.LocalMapStats getLocalMapStats()

Specified by:

getLocalMapStats in interface com.hazelcast.core.IMap<K,V>

keySet

public Set<K> keySet(com.hazelcast.query.Predicate predicate)

Specified by:

keySet in interface com.hazelcast.core.IMap<K,V>

localKeySet

public Set<K> localKeySet()

Specified by:

localKeySet in interface com.hazelcast.core.IMap<K,V>

localKeySet

public Set<K> localKeySet(com.hazelcast.query.Predicate predicate)

Specified by:

localKeySet in interface com.hazelcast.core.IMap<K,V>

lockMap

public boolean lockMap(long time,
                       TimeUnit timeunit)

Specified by:

lockMap in interface com.hazelcast.core.IMap<K,V>

put

public V put(K key,
             V value,
             long ttl,
             TimeUnit timeunit)

Specified by:

put in interface com.hazelcast.core.IMap<K,V>

putIfAbsent

public V putIfAbsent(K key,
                     V value,
                     long ttl,
                     TimeUnit timeunit)

Specified by:

putIfAbsent in interface com.hazelcast.core.IMap<K,V>

tryPut

public boolean tryPut(K key,
                      V value,
                      long timeout,
                      TimeUnit timeunit)

Specified by:

tryPut in interface com.hazelcast.core.IMap<K,V>

unlockMap

public void unlockMap()

Specified by:

unlockMap in interface com.hazelcast.core.IMap<K,V>

values

public Collection<V> values(com.hazelcast.query.Predicate predicate)

Specified by:

values in interface com.hazelcast.core.IMap<K,V>

getAsync

public Future<V> getAsync(K key)

Specified by:

getAsync in interface com.hazelcast.core.IMap<K,V>

putAsync

public Future<V> putAsync(K key,
                          V value)

Specified by:

putAsync in interface com.hazelcast.core.IMap<K,V>

addIndex

public void addIndex(com.hazelcast.query.Expression<?> arg0,
                     boolean arg1)

Specified by:

addIndex in interface com.hazelcast.core.IMap<K,V>

addLocalEntryListener

public void addLocalEntryListener(com.hazelcast.core.EntryListener<K,V> arg0)

Specified by:

addLocalEntryListener in interface com.hazelcast.core.IMap<K,V>

flush

public void flush()

Specified by:

flush in interface com.hazelcast.core.IMap<K,V>

getAll

public Map<K,V> getAll(Set<K> arg0)

Specified by:

getAll in interface com.hazelcast.core.IMap<K,V>

putAndUnlock

public void putAndUnlock(K arg0,
                         V arg1)

Specified by:

putAndUnlock in interface com.hazelcast.core.IMap<K,V>

putTransient

public void putTransient(K arg0,
                         V arg1,
                         long arg2,
                         TimeUnit arg3)

Specified by:

putTransient in interface com.hazelcast.core.IMap<K,V>

removeAsync

public Future<V> removeAsync(K arg0)

Specified by:

removeAsync in interface com.hazelcast.core.IMap<K,V>

tryLockAndGet

public V tryLockAndGet(K arg0,
                       long arg1,
                       TimeUnit arg2)
                throws TimeoutException

Specified by:

tryLockAndGet in interface com.hazelcast.core.IMap<K,V>

Throws:

TimeoutException

tryRemove

public Object tryRemove(K arg0,
                        long arg1,
                        TimeUnit arg2)
                 throws TimeoutException

Specified by:

tryRemove in interface com.hazelcast.core.IMap<K,V>

Throws:

TimeoutException