Package org.infinispan.client.hotrod.impl.transaction

Class TransactionalRemoteCacheImpl<K,V>

java.lang.Object

org.infinispan.client.hotrod.impl.RemoteCacheSupport<K,V>

org.infinispan.client.hotrod.impl.RemoteCacheImpl<K,V>

org.infinispan.client.hotrod.impl.transaction.TransactionalRemoteCacheImpl<K,V>

All Implemented Interfaces:

ConcurrentMap<K,V>, Map<K,V>, InternalRemoteCache<K,V>, RemoteCache<K,V>, AsyncCache<K,V>, BasicCache<K,V>, Lifecycle, TransactionalCache

public class TransactionalRemoteCacheImpl<K,V>
extends RemoteCacheImpl<K,V>

A RemoteCache implementation that handles Transaction.

All streaming operation (example RemoteCache.retrieveEntries(String, int)) and RemoteCacheSupport.size() aren't transactional in a way they don't interact with the transaction's data (keys, values).

containsValue(Object) is a special case where a key with the specific value is marked as read for the transaction.

Since:

9.3

Author:

Pedro Ruivo

Nested Class Summary

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

Map.Entry<K extends Object,V extends Object>

Field Summary

Fields inherited from class org.infinispan.client.hotrod.impl.RemoteCacheImpl

clientStatistics, operationsFactory

Fields inherited from class org.infinispan.client.hotrod.impl.RemoteCacheSupport

defaultLifespan, defaultMaxIdleTime

Constructor Summary

Constructors

Constructor	Description
TransactionalRemoteCacheImpl(RemoteCacheManager rcm, String name, boolean forceReturnValue, boolean recoveryEnabled, TransactionManager transactionManager, TransactionTable transactionTable, TimeService timeService)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<V>	computeIfAbsentAsync(K key, Function<? super K,? extends V> mappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)	Asynchronous version of BasicCache.computeIfAbsent(Object, Function, long, TimeUnit, long, TimeUnit).
CompletableFuture<V>	computeIfPresentAsync(K key, BiFunction<? super K,? super V,? extends V> remappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)	Asynchronous version of BasicCache.computeIfPresent(Object, BiFunction, long, TimeUnit, long, TimeUnit) .
CompletableFuture<Boolean>	containsKeyAsync(K key)	Asynchronous version of Map.containsKey(Object)
boolean	containsValue(Object value)
CompletableFuture<V>	getAsync(Object key)	Asynchronous version of Map.get(Object) that allows user code to retrieve the value associated with a key at a later stage, hence allowing multiple parallel get requests to be sent.
TransactionManager	getTransactionManager()
CompletableFuture<MetadataValue<V>>	getWithMetadataAsync(K key)	Asynchronously returns the MetadataValue associated to the supplied key param, or null if it doesn't exist.
boolean	isTransactional()
CompletableFuture<Void>	putAllAsync(Map<? extends K,? extends V> map, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Adds or overrides each specified entry in the remote cache.
CompletableFuture<V>	putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Asynchronous version of BasicCache.put(Object, Object, long, TimeUnit, long, TimeUnit).
CompletableFuture<V>	putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Asynchronous version of BasicCache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit).
CompletableFuture<V>	removeAsync(Object key)	Asynchronous version of BasicCache.remove(Object).
CompletableFuture<Boolean>	removeAsync(Object key, Object value)	Asynchronous version of ConcurrentMap.remove(Object, Object).
CompletableFuture<Boolean>	removeWithVersionAsync(K key, long version)
CompletableFuture<V>	replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Asynchronous version of BasicCache.replace(Object, Object, long, TimeUnit, long, TimeUnit).
CompletableFuture<Boolean>	replaceAsync(K key, V oldValue, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Asynchronous version of BasicCache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit).
CompletableFuture<Boolean>	replaceWithVersionAsync(K key, V newValue, long version, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)

Methods inherited from class org.infinispan.client.hotrod.impl.RemoteCacheImpl

addClientListener, addClientListener, addNearCacheListener, assertRemoteCacheManagerIsStarted, clearAsync, clientStatistics, computeAsync, continuousQuery, entryIterator, entrySet, execute, execute, getAllAsync, getCacheTopologyInfo, getDataFormat, getName, getOperationsFactory, getProtocolVersion, getRemoteCacheContainer, getVersion, getWithMetadataAsync, hasForceReturnFlag, init, init, isEmpty, isObjectStorage, keyIterator, keySet, keyToBytes, mergeAsync, ping, publishEntries, publishEntriesByQuery, publishEntriesWithMetadata, query, removeClientListener, replaceAll, resolveStorage, resolveStorage, retrieveEntries, retrieveEntriesByQuery, retrieveEntriesWithMetadata, serverStatistics, serverStatisticsAsync, sizeAsync, start, stop, streaming, toString, updateBloomFilter, values, valueToBytes, withDataFormat, withFlags

Methods inherited from class org.infinispan.client.hotrod.impl.RemoteCacheSupport

clear, compute, compute, compute, computeAsync, computeAsync, computeIfAbsent, computeIfAbsent, computeIfAbsent, computeIfAbsentAsync, computeIfAbsentAsync, computeIfPresent, computeIfPresent, computeIfPresent, computeIfPresentAsync, computeIfPresentAsync, containsKey, get, getAll, getWithMetadata, merge, merge, merge, mergeAsync, mergeAsync, put, put, put, putAll, putAll, putAll, putAllAsync, putAllAsync, putAsync, putAsync, putIfAbsent, putIfAbsent, putIfAbsent, putIfAbsentAsync, putIfAbsentAsync, remove, remove, removeWithVersion, replace, replace, replace, replace, replace, replace, replaceAsync, replaceAsync, replaceAsync, replaceAsync, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersionAsync, replaceWithVersionAsync, replaceWithVersionAsync, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commons.api.AsyncCache

computeAsync, computeAsync, computeIfAbsentAsync, computeIfAbsentAsync, computeIfPresentAsync, computeIfPresentAsync, mergeAsync, mergeAsync, putAsync, putAsync, putIfAbsentAsync, putIfAbsentAsync, replaceAsync, replaceAsync, replaceAsync, replaceAsync

Methods inherited from interface org.infinispan.commons.api.BasicCache

compute, compute, computeIfAbsent, computeIfAbsent, computeIfPresent, computeIfPresent, merge, merge, put, put, put, putIfAbsent, putIfAbsent, replace, replace

Methods inherited from interface java.util.concurrent.ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, replace

Methods inherited from interface org.infinispan.client.hotrod.impl.InternalRemoteCache

removeEntry, removeEntry

Methods inherited from interface java.util.Map

clear, containsKey, equals, get, hashCode, size

Methods inherited from interface org.infinispan.client.hotrod.RemoteCache

entrySet, execute, getAll, getRemoteCacheManager, getWithMetadata, keySet, putAll, putAll, putAll, putAllAsync, putAllAsync, remove, remove, removeWithVersion, replace, replace, replace, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersionAsync, replaceWithVersionAsync, replaceWithVersionAsync, retrieveEntries, retrieveEntries, values

Constructor Details

TransactionalRemoteCacheImpl

public TransactionalRemoteCacheImpl(RemoteCacheManager rcm,
 String name,
 boolean forceReturnValue,
 boolean recoveryEnabled,
 TransactionManager transactionManager,
 TransactionTable transactionTable,
 TimeService timeService)

Method Details

removeWithVersionAsync

public CompletableFuture<Boolean> removeWithVersionAsync(K key,
 long version)

Specified by:

removeWithVersionAsync in interface RemoteCache<K,V>

Overrides:

removeWithVersionAsync in class RemoteCacheImpl<K,V>

See Also:

• RemoteCache.remove(Object, Object)

replaceWithVersionAsync

public CompletableFuture<Boolean> replaceWithVersionAsync(K key,
 V newValue,
 long version,
 long lifespan,
 TimeUnit lifespanTimeUnit,
 long maxIdle,
 TimeUnit maxIdleTimeUnit)

Specified by:

replaceWithVersionAsync in interface RemoteCache<K,V>

Overrides:

replaceWithVersionAsync in class RemoteCacheImpl<K,V>

See Also:

• RemoteCache.replaceWithVersion(Object, Object, long)

getWithMetadataAsync

public CompletableFuture<MetadataValue<V>> getWithMetadataAsync(K key)

Description copied from interface: RemoteCache

Asynchronously returns the MetadataValue associated to the supplied key param, or null if it doesn't exist.

Specified by:

getWithMetadataAsync in interface RemoteCache<K,V>

Overrides:

getWithMetadataAsync in class RemoteCacheImpl<K,V>

putAllAsync

public CompletableFuture<Void> putAllAsync(Map<? extends K,? extends V> map,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdleTime,
 TimeUnit maxIdleTimeUnit)

Description copied from interface: RemoteCache

Adds or overrides each specified entry in the remote cache. This operation provides better performance than calling put() for each entry.

Specified by:

putAllAsync in interface AsyncCache<K,V>

Specified by:

putAllAsync in interface RemoteCache<K,V>

Overrides:

putAllAsync in class RemoteCacheImpl<K,V>

Parameters:

map - to store

lifespan - lifespan of entry

lifespanUnit - time unit for lifespan

maxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as expired

maxIdleTimeUnit - time unit for max idle time

Returns:

a future containing a void return type

See Also:

• RemoteCache.putAll(java.util.Map, long, java.util.concurrent.TimeUnit)

putAsync

public CompletableFuture<V> putAsync(K key,
 V value,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdleTime,
 TimeUnit maxIdleTimeUnit)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.put(Object, Object, long, TimeUnit, long, TimeUnit). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

putAsync in interface AsyncCache<K,V>

Overrides:

putAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to use

value - value to store

lifespan - lifespan of entry

lifespanUnit - time unit for lifespan

maxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as expired

maxIdleTimeUnit - time unit for max idle time

Returns:

a future containing the old value replaced

putIfAbsentAsync

public CompletableFuture<V> putIfAbsentAsync(K key,
 V value,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdleTime,
 TimeUnit maxIdleTimeUnit)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

putIfAbsentAsync in interface AsyncCache<K,V>

Overrides:

putIfAbsentAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to use

value - value to store

lifespan - lifespan of entry

lifespanUnit - time unit for lifespan

maxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as expired

maxIdleTimeUnit - time unit for max idle time

Returns:

a future containing the old value replaced

replaceAsync

public CompletableFuture<V> replaceAsync(K key,
 V value,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdleTime,
 TimeUnit maxIdleTimeUnit)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.replace(Object, Object, long, TimeUnit, long, TimeUnit). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

replaceAsync in interface AsyncCache<K,V>

Overrides:

replaceAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to remove

value - value to store

lifespan - lifespan of entry

lifespanUnit - time unit for lifespan

maxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as expired

maxIdleTimeUnit - time unit for max idle time

Returns:

a future containing the previous value overwritten

replaceAsync

public CompletableFuture<Boolean> replaceAsync(K key,
 V oldValue,
 V value,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdleTime,
 TimeUnit maxIdleTimeUnit)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

replaceAsync in interface AsyncCache<K,V>

Overrides:

replaceAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to remove

oldValue - value to overwrite

value - value to store

lifespan - lifespan of entry

lifespanUnit - time unit for lifespan

maxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as expired

maxIdleTimeUnit - time unit for max idle time

Returns:

a future containing a boolean, indicating whether the entry was replaced or not

containsKeyAsync

public CompletableFuture<Boolean> containsKeyAsync(K key)

Description copied from interface: AsyncCache

Asynchronous version of Map.containsKey(Object)

Specified by:

containsKeyAsync in interface AsyncCache<K,V>

Overrides:

containsKeyAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to retrieve

Returns:

future containing true if the mapping exists.

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<K,V>

Overrides:

containsValue in class RemoteCacheImpl<K,V>

getAsync

public CompletableFuture<V> getAsync(Object key)

Description copied from interface: AsyncCache

Asynchronous version of Map.get(Object) that allows user code to retrieve the value associated with a key at a later stage, hence allowing multiple parallel get requests to be sent. Normally, when this method detects that the value is likely to be retrieved from from a remote entity, it will span a different thread in order to allow the asynchronous get call to return immediately. If the call will definitely resolve locally, for example when the cache is configured with LOCAL mode and no stores are configured, the get asynchronous call will act sequentially and will have no different to Map.get(Object).

Specified by:

getAsync in interface AsyncCache<K,V>

Overrides:

getAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to retrieve

Returns:

a future that can be used to retrieve value associated with the key when this is available. The actual value returned by the future follows the same rules as Map.get(Object)

removeAsync

public CompletableFuture<V> removeAsync(Object key)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.remove(Object). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

removeAsync in interface AsyncCache<K,V>

Overrides:

removeAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to remove

Returns:

a future containing the value removed

removeAsync

public CompletableFuture<Boolean> removeAsync(Object key,
 Object value)

Description copied from interface: AsyncCache

Asynchronous version of ConcurrentMap.remove(Object, Object). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

removeAsync in interface AsyncCache<K,V>

Overrides:

removeAsync in class RemoteCacheImpl<K,V>

Parameters:

key - key to remove

value - value to match on

Returns:

a future containing a boolean, indicating whether the entry was removed or not

computeIfAbsentAsync

public CompletableFuture<V> computeIfAbsentAsync(K key,
 Function<? super K,? extends V> mappingFunction,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdle,
 TimeUnit maxIdleUnit)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.computeIfAbsent(Object, Function, long, TimeUnit, long, TimeUnit). This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

computeIfAbsentAsync in interface AsyncCache<K,V>

Overrides:

computeIfAbsentAsync in class RemoteCacheImpl<K,V>

computeIfPresentAsync

public CompletableFuture<V> computeIfPresentAsync(K key,
 BiFunction<? super K,? super V,? extends V> remappingFunction,
 long lifespan,
 TimeUnit lifespanUnit,
 long maxIdle,
 TimeUnit maxIdleUnit)

Description copied from interface: AsyncCache

Asynchronous version of BasicCache.computeIfPresent(Object, BiFunction, long, TimeUnit, long, TimeUnit) . This method does not block on remote calls, even if your cache mode is synchronous.

Specified by:

computeIfPresentAsync in interface AsyncCache<K,V>

Overrides:

computeIfPresentAsync in class RemoteCacheImpl<K,V>

getTransactionManager

public TransactionManager getTransactionManager()

Returns:

the TransactionManager in use by this cache or null if the cache isn't transactional.

isTransactional

public boolean isTransactional()

Specified by:

isTransactional in interface RemoteCache<K,V>

Overrides:

isTransactional in class RemoteCacheImpl<K,V>

Returns:

true if the cache can participate in a transaction, false otherwise.