org.jboss.as.clustering.infinispan.atomic

Class AtomicMapCache<K,MK,MV>

java.lang.Object

org.infinispan.AbstractDelegatingCache<K,V>

org.infinispan.AbstractDelegatingAdvancedCache<K,V>

org.jboss.as.clustering.infinispan.AbstractAdvancedCache<K,Map<MK,MV>>

org.jboss.as.clustering.infinispan.atomic.AtomicMapCache<K,MK,MV>

All Implemented Interfaces:

ConcurrentMap<K,Map<MK,MV>>, Map<K,Map<MK,MV>>, org.infinispan.AdvancedCache<K,Map<MK,MV>>, org.infinispan.api.BasicCache<K,Map<MK,MV>>, org.infinispan.Cache<K,Map<MK,MV>>, org.infinispan.lifecycle.Lifecycle, org.infinispan.notifications.Listenable

public class AtomicMapCache<K,MK,MV>
extends AbstractAdvancedCache<K,Map<MK,MV>>

Nested Class Summary

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

Map.Entry<K,V>

Field Summary

Fields inherited from class org.infinispan.AbstractDelegatingAdvancedCache

cache

Constructor Summary

Constructors

Constructor and Description
AtomicMapCache(org.infinispan.AdvancedCache<K,Map<MK,MV>> cache)

Method Summary

Methods

Modifier and Type	Method and Description
Map<MK,MV>	get(Object key)
Map<MK,MV>	put(K key, Map<MK,MV> value)
Map<MK,MV>	put(K key, Map<MK,MV> value, long lifespan, TimeUnit unit)
Map<MK,MV>	put(K key, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
void	putAll(Map<? extends K,? extends Map<MK,MV>> map, long lifespan, TimeUnit unit)
void	putAll(Map<? extends K,? extends Map<MK,MV>> map, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
org.infinispan.util.concurrent.NotifyingFuture<Void>	putAllAsync(Map<? extends K,? extends Map<MK,MV>> data)
org.infinispan.util.concurrent.NotifyingFuture<Void>	putAllAsync(Map<? extends K,? extends Map<MK,MV>> data, long lifespan, TimeUnit unit)
org.infinispan.util.concurrent.NotifyingFuture<Void>	putAllAsync(Map<? extends K,? extends Map<MK,MV>> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	putAsync(K key, Map<MK,MV> value)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	putAsync(K key, Map<MK,MV> value, long lifespan, TimeUnit unit)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	putAsync(K key, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
void	putForExternalRead(K key, Map<MK,MV> value)
Map<MK,MV>	putIfAbsent(K key, Map<MK,MV> value)
Map<MK,MV>	putIfAbsent(K key, Map<MK,MV> value, long lifespan, TimeUnit unit)
Map<MK,MV>	putIfAbsent(K key, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	putIfAbsentAsync(K key, Map<MK,MV> value)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	putIfAbsentAsync(K key, Map<MK,MV> value, long lifespan, TimeUnit unit)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	putIfAbsentAsync(K key, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
Map<MK,MV>	replace(K key, Map<MK,MV> value)
Map<MK,MV>	replace(K key, Map<MK,MV> value, long lifespan, TimeUnit unit)
Map<MK,MV>	replace(K key, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
boolean	replace(K key, Map<MK,MV> oldValue, Map<MK,MV> newValue)
boolean	replace(K key, Map<MK,MV> oldValue, Map<MK,MV> value, long lifespan, TimeUnit unit)
boolean	replace(K key, Map<MK,MV> oldValue, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	replaceAsync(K key, Map<MK,MV> value)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	replaceAsync(K key, Map<MK,MV> value, long lifespan, TimeUnit unit)
org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>>	replaceAsync(K key, Map<MK,MV> value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
org.infinispan.util.concurrent.NotifyingFuture<Boolean>	replaceAsync(K key, Map<MK,MV> oldValue, Map<MK,MV> newValue)
org.infinispan.util.concurrent.NotifyingFuture<Boolean>	replaceAsync(K key, Map<MK,MV> oldValue, Map<MK,MV> newValue, long lifespan, TimeUnit unit)
org.infinispan.util.concurrent.NotifyingFuture<Boolean>	replaceAsync(K key, Map<MK,MV> oldValue, Map<MK,MV> newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
protected org.infinispan.AdvancedCache<K,Map<MK,MV>>	wrap(org.infinispan.AdvancedCache<K,Map<MK,MV>> cache)

Methods inherited from class org.jboss.as.clustering.infinispan.AbstractAdvancedCache

with, withFlags

Methods inherited from class org.infinispan.AbstractDelegatingAdvancedCache

addInterceptor, addInterceptorAfter, addInterceptorBefore, applyDelta, getAdvancedCache, getBatchContainer, getClassLoader, getComponentRegistry, getDataContainer, getDistributionManager, getEvictionManager, getInterceptorChain, getInvocationContextContainer, getLockManager, getRpcManager, getStats, getTransactionManager, getXAResource, lock, lock, removeInterceptor, removeInterceptor

Methods inherited from class org.infinispan.AbstractDelegatingCache

addListener, clear, clearAsync, compact, containsKey, containsValue, endBatch, entrySet, evict, getAsync, getCacheConfiguration, getCacheManager, getConfiguration, getListeners, getName, getStatus, getVersion, isEmpty, keySet, putAll, remove, remove, removeAsync, removeAsync, removeListener, set, size, start, startBatch, stop, toString, values

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.Cache

compact, endBatch, entrySet, evict, getCacheConfiguration, getCacheManager, getConfiguration, getStatus, keySet, startBatch, values

Methods inherited from interface org.infinispan.api.BasicCache

clearAsync, getAsync, getName, getVersion, removeAsync, removeAsync

Methods inherited from interface java.util.concurrent.ConcurrentMap

remove

Methods inherited from interface java.util.Map

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

Methods inherited from interface org.infinispan.lifecycle.Lifecycle

start, stop

Methods inherited from interface org.infinispan.notifications.Listenable

addListener, getListeners, removeListener

Constructor Detail

AtomicMapCache

public AtomicMapCache(org.infinispan.AdvancedCache<K,Map<MK,MV>> cache)

Method Detail

wrap

protected org.infinispan.AdvancedCache<K,Map<MK,MV>> wrap(org.infinispan.AdvancedCache<K,Map<MK,MV>> cache)

Specified by:

wrap in class AbstractAdvancedCache<K,Map<MK,MV>>

get

public Map<MK,MV> get(Object key)

Specified by:

get in interface Map<K,Map<MK,MV>>

Overrides:

get in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putIfAbsent

public Map<MK,MV> putIfAbsent(K key,
                     Map<MK,MV> value)

Specified by:

putIfAbsent in interface ConcurrentMap<K,Map<MK,MV>>

Overrides:

putIfAbsent in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putForExternalRead

public void putForExternalRead(K key,
                      Map<MK,MV> value)

Specified by:

putForExternalRead in interface org.infinispan.Cache<K,Map<MK,MV>>

Overrides:

putForExternalRead in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

put

public Map<MK,MV> put(K key,
             Map<MK,MV> value,
             long lifespan,
             TimeUnit unit)

Specified by:

put in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

put in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putIfAbsent

public Map<MK,MV> putIfAbsent(K key,
                     Map<MK,MV> value,
                     long lifespan,
                     TimeUnit unit)

Specified by:

putIfAbsent in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putIfAbsent in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAll

public void putAll(Map<? extends K,? extends Map<MK,MV>> map,
          long lifespan,
          TimeUnit unit)

Specified by:

putAll in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAll in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replace

public Map<MK,MV> replace(K key,
                 Map<MK,MV> value,
                 long lifespan,
                 TimeUnit unit)

Specified by:

replace in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replace in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replace

public boolean replace(K key,
              Map<MK,MV> oldValue,
              Map<MK,MV> value,
              long lifespan,
              TimeUnit unit)

Specified by:

replace in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replace in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

put

public Map<MK,MV> put(K key,
             Map<MK,MV> value,
             long lifespan,
             TimeUnit lifespanUnit,
             long maxIdleTime,
             TimeUnit maxIdleTimeUnit)

Specified by:

put in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

put in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putIfAbsent

public Map<MK,MV> putIfAbsent(K key,
                     Map<MK,MV> value,
                     long lifespan,
                     TimeUnit lifespanUnit,
                     long maxIdleTime,
                     TimeUnit maxIdleTimeUnit)

Specified by:

putIfAbsent in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putIfAbsent in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAll

public void putAll(Map<? extends K,? extends Map<MK,MV>> map,
          long lifespan,
          TimeUnit lifespanUnit,
          long maxIdleTime,
          TimeUnit maxIdleTimeUnit)

Specified by:

putAll in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAll in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replace

public Map<MK,MV> replace(K key,
                 Map<MK,MV> value,
                 long lifespan,
                 TimeUnit lifespanUnit,
                 long maxIdleTime,
                 TimeUnit maxIdleTimeUnit)

Specified by:

replace in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replace in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replace

public boolean replace(K key,
              Map<MK,MV> oldValue,
              Map<MK,MV> value,
              long lifespan,
              TimeUnit lifespanUnit,
              long maxIdleTime,
              TimeUnit maxIdleTimeUnit)

Specified by:

replace in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replace in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> putAsync(K key,
                                                                  Map<MK,MV> value)

Specified by:

putAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> putAsync(K key,
                                                                  Map<MK,MV> value,
                                                                  long lifespan,
                                                                  TimeUnit unit)

Specified by:

putAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> putAsync(K key,
                                                                  Map<MK,MV> value,
                                                                  long lifespan,
                                                                  TimeUnit lifespanUnit,
                                                                  long maxIdle,
                                                                  TimeUnit maxIdleUnit)

Specified by:

putAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAllAsync

public org.infinispan.util.concurrent.NotifyingFuture<Void> putAllAsync(Map<? extends K,? extends Map<MK,MV>> data)

Specified by:

putAllAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAllAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAllAsync

public org.infinispan.util.concurrent.NotifyingFuture<Void> putAllAsync(Map<? extends K,? extends Map<MK,MV>> data,
                                                               long lifespan,
                                                               TimeUnit unit)

Specified by:

putAllAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAllAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putAllAsync

public org.infinispan.util.concurrent.NotifyingFuture<Void> putAllAsync(Map<? extends K,? extends Map<MK,MV>> data,
                                                               long lifespan,
                                                               TimeUnit lifespanUnit,
                                                               long maxIdle,
                                                               TimeUnit maxIdleUnit)

Specified by:

putAllAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putAllAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putIfAbsentAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> putIfAbsentAsync(K key,
                                                                          Map<MK,MV> value)

Specified by:

putIfAbsentAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putIfAbsentAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putIfAbsentAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> putIfAbsentAsync(K key,
                                                                          Map<MK,MV> value,
                                                                          long lifespan,
                                                                          TimeUnit unit)

Specified by:

putIfAbsentAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putIfAbsentAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

putIfAbsentAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> putIfAbsentAsync(K key,
                                                                          Map<MK,MV> value,
                                                                          long lifespan,
                                                                          TimeUnit lifespanUnit,
                                                                          long maxIdle,
                                                                          TimeUnit maxIdleUnit)

Specified by:

putIfAbsentAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

putIfAbsentAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replaceAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> replaceAsync(K key,
                                                                      Map<MK,MV> value)

Specified by:

replaceAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replaceAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replaceAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> replaceAsync(K key,
                                                                      Map<MK,MV> value,
                                                                      long lifespan,
                                                                      TimeUnit unit)

Specified by:

replaceAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replaceAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replaceAsync

public org.infinispan.util.concurrent.NotifyingFuture<Map<MK,MV>> replaceAsync(K key,
                                                                      Map<MK,MV> value,
                                                                      long lifespan,
                                                                      TimeUnit lifespanUnit,
                                                                      long maxIdle,
                                                                      TimeUnit maxIdleUnit)

Specified by:

replaceAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replaceAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replaceAsync

public org.infinispan.util.concurrent.NotifyingFuture<Boolean> replaceAsync(K key,
                                                                   Map<MK,MV> oldValue,
                                                                   Map<MK,MV> newValue)

Specified by:

replaceAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replaceAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replaceAsync

public org.infinispan.util.concurrent.NotifyingFuture<Boolean> replaceAsync(K key,
                                                                   Map<MK,MV> oldValue,
                                                                   Map<MK,MV> newValue,
                                                                   long lifespan,
                                                                   TimeUnit unit)

Specified by:

replaceAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replaceAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replaceAsync

public org.infinispan.util.concurrent.NotifyingFuture<Boolean> replaceAsync(K key,
                                                                   Map<MK,MV> oldValue,
                                                                   Map<MK,MV> newValue,
                                                                   long lifespan,
                                                                   TimeUnit lifespanUnit,
                                                                   long maxIdle,
                                                                   TimeUnit maxIdleUnit)

Specified by:

replaceAsync in interface org.infinispan.api.BasicCache<K,Map<MK,MV>>

Overrides:

replaceAsync in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replace

public boolean replace(K key,
              Map<MK,MV> oldValue,
              Map<MK,MV> newValue)

Specified by:

replace in interface ConcurrentMap<K,Map<MK,MV>>

Overrides:

replace in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

replace

public Map<MK,MV> replace(K key,
                 Map<MK,MV> value)

Specified by:

replace in interface ConcurrentMap<K,Map<MK,MV>>

Overrides:

replace in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>

put

public Map<MK,MV> put(K key,
             Map<MK,MV> value)

Specified by:

put in interface Map<K,Map<MK,MV>>

Overrides:

put in class org.infinispan.AbstractDelegatingCache<K,Map<MK,MV>>