public class RemoteCacheImpl<K,V> extends RemoteCacheSupport<K,V> implements InternalRemoteCache<K,V>
| Modifier and Type | Field and Description |
|---|---|
protected ClientStatistics |
clientStatistics |
protected OperationsFactory |
operationsFactory |
defaultLifespan, defaultMaxIdleTime| Modifier | Constructor and Description |
|---|---|
protected |
RemoteCacheImpl(RemoteCacheManager rcm,
String name,
ClientStatistics clientStatistics) |
|
RemoteCacheImpl(RemoteCacheManager rcm,
String name,
TimeService timeService) |
|
RemoteCacheImpl(RemoteCacheManager rcm,
String name,
TimeService timeService,
NearCacheService<K,V> nearCacheService) |
| Modifier and Type | Method and Description |
|---|---|
void |
addClientListener(Object listener)
Add a client listener to receive events that happen in the remote cache.
|
void |
addClientListener(Object listener,
Object[] filterFactoryParams,
Object[] converterFactoryParams)
Add a client listener to receive events that happen in the remote cache.
|
protected void |
assertRemoteCacheManagerIsStarted() |
CompletableFuture<Void> |
clearAsync()
Asynchronous version of
Map.clear(). |
ClientStatistics |
clientStatistics()
Returns client-side statistics for this cache.
|
CompletableFuture<V> |
computeAsync(K key,
BiFunction<? super K,? super V,? extends V> remappingFunction,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
Asynchronous version of
BasicCache.compute(Object, BiFunction, long, TimeUnit, long, TimeUnit). |
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) |
CloseableIterator<Map.Entry<K,V>> |
entryIterator(IntSet segments) |
CloseableIteratorSet<Map.Entry<K,V>> |
entrySet(IntSet segments)
This method is identical to
RemoteCache.entrySet() except that it will only return entries that map to the given segments. |
<T> T |
execute(String taskName,
Map<String,?> params)
Executes a remote task passing a set of named parameters
|
<T> T |
execute(String taskName,
Map<String,?> params,
Object key)
Executes a remote task passing a set of named parameters, hinting that the task should be executed
on the server that is expected to store given key.
|
CompletableFuture<Map<K,V>> |
getAllAsync(Set<?> keys)
TODO This should be in AdvancedCache with getAll
|
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. |
CacheTopologyInfo |
getCacheTopologyInfo()
Returns
CacheTopologyInfo for this cache. |
DataFormat |
getDataFormat()
Return the currently
DataFormat being used. |
Set<Object> |
getListeners()
Deprecated.
|
String |
getName()
Retrieves the name of the cache
|
OperationsFactory |
getOperationsFactory() |
String |
getProtocolVersion()
Returns the HotRod protocol version supported by this RemoteCache implementation
|
RemoteCacheManager |
getRemoteCacheManager()
Returns the
RemoteCacheManager that created this cache. |
String |
getVersion()
Retrieves the version of Infinispan
|
CompletableFuture<MetadataValue<V>> |
getWithMetadataAsync(K key)
Asynchronously returns the
MetadataValue associated to the supplied key param, or null if it doesn't exist. |
boolean |
hasForceReturnFlag() |
void |
init(Marshaller marshaller,
OperationsFactory operationsFactory,
Configuration configuration)
Inititalize without mbeans
|
void |
init(Marshaller marshaller,
OperationsFactory operationsFactory,
Configuration configuration,
ObjectName jmxParent) |
boolean |
isEmpty() |
boolean |
isObjectStorage() |
boolean |
isTransactional() |
K |
keyAsObjectIfNeeded(Object key) |
CloseableIterator<K> |
keyIterator(IntSet segments) |
CloseableIteratorSet<K> |
keySet(IntSet segments)
This method is identical to
RemoteCache.keySet() except that it will only return keys that map to the given segments. |
byte[] |
keyToBytes(Object o) |
CompletableFuture<V> |
mergeAsync(K key,
V value,
BiFunction<? super V,? super V,? extends V> remappingFunction,
long lifespan,
TimeUnit lifespanUnit,
long maxIdleTime,
TimeUnit maxIdleTimeUnit)
Asynchronous version of
BasicCache.merge(Object, Object, BiFunction, long, TimeUnit, long, TimeUnit). |
PingResponse |
ping() |
<E> org.reactivestreams.Publisher<Map.Entry<K,E>> |
publishEntries(String filterConverterFactory,
Object[] filterConverterParams,
Set<Integer> segments,
int batchSize)
Publishes the entries from the server in a non blocking fashion.
|
<E> org.reactivestreams.Publisher<Map.Entry<K,E>> |
publishEntriesByQuery(org.infinispan.query.dsl.Query<?> filterQuery,
Set<Integer> segments,
int batchSize)
Publish entries from the server matching a query.
|
org.reactivestreams.Publisher<Map.Entry<K,MetadataValue<V>>> |
publishEntriesWithMetadata(Set<Integer> segments,
int batchSize)
Publish entries with metadata information
|
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). |
void |
removeClientListener(Object listener)
Remove a previously added client listener.
|
CompletableFuture<Boolean> |
removeWithVersionAsync(K key,
long version) |
void |
replaceAll(BiFunction<? super K,? super V,? extends V> function) |
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 newValue,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
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) |
void |
resolveStorage(boolean objectStorage) |
CloseableIterator<Map.Entry<Object,Object>> |
retrieveEntries(String filterConverterFactory,
Object[] filterConverterParams,
Set<Integer> segments,
int batchSize)
Retrieve entries from the server.
|
CloseableIterator<Map.Entry<Object,Object>> |
retrieveEntriesByQuery(org.infinispan.query.dsl.Query<?> filterQuery,
Set<Integer> segments,
int batchSize)
Retrieve entries from the server matching a query.
|
CloseableIterator<Map.Entry<Object,MetadataValue<Object>>> |
retrieveEntriesWithMetadata(Set<Integer> segments,
int batchSize)
Retrieve entries with metadata information
|
ServerStatistics |
serverStatistics()
Returns server-side statistics for this cache.
|
CompletableFuture<Long> |
sizeAsync()
Asynchronous version of
Map.size(). |
void |
start()
Invoked on component start
|
void |
stop()
Invoked on component stop
|
StreamingRemoteCache<K> |
streaming()
Returns a cache where values are manipulated using
InputStream and OutputStream |
CloseableIteratorCollection<V> |
values(IntSet segments)
This method is identical to
RemoteCache.values() except that it will only return values that map to the given segments. |
protected byte[] |
valueToBytes(Object o) |
<T,U> InternalRemoteCache<T,U> |
withDataFormat(DataFormat newDataFormat)
Return a new instance of
RemoteCache using the supplied DataFormat. |
InternalRemoteCache<K,V> |
withFlags(Flag... flags)
Applies one or more
Flags to the scope of a single invocation. |
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, sizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitremoveEntry, removeEntryentrySet, getAll, getWithMetadata, keySet, putAll, putAll, putAll, putAllAsync, putAllAsync, remove, remove, removeWithVersion, replace, replace, replace, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersionAsync, replaceWithVersionAsync, replaceWithVersionAsync, retrieveEntries, retrieveEntries, stats, valuescompute, compute, computeIfAbsent, computeIfAbsent, computeIfPresent, computeIfPresent, merge, merge, put, put, put, putIfAbsent, putIfAbsent, replace, replacecomputeAsync, computeAsync, computeIfAbsentAsync, computeIfAbsentAsync, computeIfPresentAsync, computeIfPresentAsync, mergeAsync, mergeAsync, putAsync, putAsync, putIfAbsentAsync, putIfAbsentAsync, replaceAsync, replaceAsync, replaceAsync, replaceAsynccompute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, replacegetTransactionManagerprotected OperationsFactory operationsFactory
protected ClientStatistics clientStatistics
public RemoteCacheImpl(RemoteCacheManager rcm, String name, TimeService timeService)
public RemoteCacheImpl(RemoteCacheManager rcm, String name, TimeService timeService, NearCacheService<K,V> nearCacheService)
protected RemoteCacheImpl(RemoteCacheManager rcm, String name, ClientStatistics clientStatistics)
public void init(Marshaller marshaller, OperationsFactory operationsFactory, Configuration configuration, ObjectName jmxParent)
init in interface InternalRemoteCache<K,V>public void init(Marshaller marshaller, OperationsFactory operationsFactory, Configuration configuration)
init in interface InternalRemoteCache<K,V>public OperationsFactory getOperationsFactory()
getOperationsFactory in interface InternalRemoteCache<K,V>public RemoteCacheManager getRemoteCacheManager()
RemoteCacheRemoteCacheManager that created this cache.getRemoteCacheManager in interface RemoteCache<K,V>public CompletableFuture<Boolean> removeWithVersionAsync(K key, long version)
removeWithVersionAsync in interface RemoteCache<K,V>removeWithVersionAsync in class RemoteCacheSupport<K,V>RemoteCache.remove(Object, Object)public CompletableFuture<V> mergeAsync(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
AsyncCacheBasicCache.merge(Object, Object, BiFunction, long, TimeUnit, long, TimeUnit). This
method does not block on remote calls, even if your cache mode is synchronous.mergeAsync in interface AsyncCache<K,V>mergeAsync in class RemoteCacheSupport<K,V>public CompletableFuture<Boolean> replaceWithVersionAsync(K key, V newValue, long version, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)
replaceWithVersionAsync in interface RemoteCache<K,V>RemoteCache.replaceWithVersion(Object, Object, long)public CloseableIterator<Map.Entry<Object,Object>> retrieveEntries(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize)
RemoteCacheretrieveEntries in interface RemoteCache<K,V>filterConverterFactory - Factory name for the KeyValueFilterConverter or null for no filtering.filterConverterParams - Parameters to the KeyValueFilterConvertersegments - The segments to iterate. If null all segments will be iterated. An empty set will filter out all entries.batchSize - The number of entries transferred from the server at a time.public <E> org.reactivestreams.Publisher<Map.Entry<K,E>> publishEntries(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize)
RemoteCacheAny subscriber that subscribes to the returned Publisher must not block. It is therefore recommended to offload any blocking or long running operations to a different thread and not use the invoking one. Failure to do so may cause concurrent operations to stall.
publishEntries in interface RemoteCache<K,V>filterConverterFactory - Factory name for the KeyValueFilterConverter or null for no filtering.filterConverterParams - Parameters to the KeyValueFilterConvertersegments - The segments to utilize. If null all segments will be utilized. An empty set will filter out all entries.batchSize - The number of entries transferred from the server at a time.public CloseableIterator<Map.Entry<Object,Object>> retrieveEntriesByQuery(org.infinispan.query.dsl.Query<?> filterQuery, Set<Integer> segments, int batchSize)
RemoteCacheretrieveEntriesByQuery in interface RemoteCache<K,V>filterQuery - Querysegments - The segments to iterate. If null all segments will be iterated. An empty set will filter out all entries.batchSize - The number of entries transferred from the server at a time.CloseableIteratorpublic <E> org.reactivestreams.Publisher<Map.Entry<K,E>> publishEntriesByQuery(org.infinispan.query.dsl.Query<?> filterQuery, Set<Integer> segments, int batchSize)
RemoteCacheAny subscriber that subscribes to the returned Publisher must not block. It is therefore recommended to offload any blocking or long running operations to a different thread and not use the invoking one. Failure to do so may cause concurrent operations to stall.
publishEntriesByQuery in interface RemoteCache<K,V>filterQuery - Querysegments - The segments to utilize. If null all segments will be utilized. An empty set will filter out all entries.batchSize - The number of entries transferred from the server at a time.public CloseableIterator<Map.Entry<Object,MetadataValue<Object>>> retrieveEntriesWithMetadata(Set<Integer> segments, int batchSize)
RemoteCacheretrieveEntriesWithMetadata in interface RemoteCache<K,V>public org.reactivestreams.Publisher<Map.Entry<K,MetadataValue<V>>> publishEntriesWithMetadata(Set<Integer> segments, int batchSize)
RemoteCacheAny subscriber that subscribes to the returned Publisher must not block. It is therefore recommended to offload any blocking or long running operations to a different thread and not use the invoking one. Failure to do so may cause concurrent operations to stall.
publishEntriesWithMetadata in interface RemoteCache<K,V>segments - The segments to utilize. If null all segments will be utilized. An empty set will filter out all entries.batchSize - The number of entries transferred from the server at a time.public CompletableFuture<MetadataValue<V>> getWithMetadataAsync(K key)
RemoteCacheMetadataValue associated to the supplied key param, or null if it doesn't exist.getWithMetadataAsync in interface RemoteCache<K,V>getWithMetadataAsync in class RemoteCacheSupport<K,V>public CompletableFuture<Void> putAllAsync(Map<? extends K,? extends V> map, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
RemoteCacheputAllAsync in interface RemoteCache<K,V>putAllAsync in interface AsyncCache<K,V>putAllAsync in class RemoteCacheSupport<K,V>map - to storelifespan - lifespan of entrylifespanUnit - time unit for lifespanmaxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as
expiredmaxIdleTimeUnit - time unit for max idle timeRemoteCache.putAll(java.util.Map, long, java.util.concurrent.TimeUnit)public CompletableFuture<Long> sizeAsync()
AsyncCacheMap.size(). This method does not block on remote calls, even if your cache mode is
synchronous.sizeAsync in interface AsyncCache<K,V>sizeAsync in class RemoteCacheSupport<K,V>public ClientStatistics clientStatistics()
RemoteCacheclientStatistics in interface InternalRemoteCache<K,V>clientStatistics in interface RemoteCache<K,V>public ServerStatistics serverStatistics()
RemoteCacheserverStatistics in interface RemoteCache<K,V>public K keyAsObjectIfNeeded(Object key)
keyAsObjectIfNeeded in interface InternalRemoteCache<K,V>public CompletableFuture<V> putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
AsyncCacheBasicCache.put(Object, Object, long, TimeUnit, long, TimeUnit). This method does not block
on remote calls, even if your cache mode is synchronous.putAsync in interface AsyncCache<K,V>putAsync in class RemoteCacheSupport<K,V>key - key to usevalue - value to storelifespan - lifespan of entrylifespanUnit - time unit for lifespanmaxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as
expiredmaxIdleTimeUnit - time unit for max idle timepublic CompletableFuture<Void> clearAsync()
AsyncCacheMap.clear(). This method does not block on remote calls, even if your cache mode is
synchronous.clearAsync in interface AsyncCache<K,V>public CompletableFuture<V> computeAsync(K key, BiFunction<? super K,? super V,? extends V> remappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
AsyncCacheBasicCache.compute(Object, BiFunction, long, TimeUnit, long, TimeUnit). This method does not block on remote
calls, even if your cache mode is synchronous.computeAsync in interface AsyncCache<K,V>computeAsync in class RemoteCacheSupport<K,V>public CompletableFuture<V> computeIfAbsentAsync(K key, Function<? super K,? extends V> mappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
AsyncCacheBasicCache.computeIfAbsent(Object, Function, long, TimeUnit, long, TimeUnit). This method does not block on remote
calls, even if your cache mode is synchronous.computeIfAbsentAsync in interface AsyncCache<K,V>computeIfAbsentAsync in class RemoteCacheSupport<K,V>public CompletableFuture<V> computeIfPresentAsync(K key, BiFunction<? super K,? super V,? extends V> remappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
AsyncCacheBasicCache.computeIfPresent(Object, BiFunction, long, TimeUnit, long, TimeUnit) . This method does not block on
remote calls, even if your cache mode is synchronous.computeIfPresentAsync in interface AsyncCache<K,V>computeIfPresentAsync in class RemoteCacheSupport<K,V>public void replaceAll(BiFunction<? super K,? super V,? extends V> function)
replaceAll in interface ConcurrentMap<K,V>replaceAll in interface Map<K,V>replaceAll in class RemoteCacheSupport<K,V>public CompletableFuture<V> putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
AsyncCacheBasicCache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit). This method does
not block on remote calls, even if your cache mode is synchronous.putIfAbsentAsync in interface AsyncCache<K,V>putIfAbsentAsync in class RemoteCacheSupport<K,V>key - key to usevalue - value to storelifespan - lifespan of entrylifespanUnit - time unit for lifespanmaxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as
expiredmaxIdleTimeUnit - time unit for max idle timepublic CompletableFuture<Boolean> replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
AsyncCacheBasicCache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit). This method
does not block on remote calls, even if your cache mode is synchronous.replaceAsync in interface AsyncCache<K,V>replaceAsync in class RemoteCacheSupport<K,V>key - key to removeoldValue - value to overwritenewValue - value to storelifespan - lifespan of entrylifespanUnit - time unit for lifespanmaxIdle - the maximum amount of time this key is allowed to be idle for before it is considered as
expiredmaxIdleUnit - time unit for max idle timepublic CompletableFuture<V> removeAsync(Object key)
AsyncCacheBasicCache.remove(Object). This method does not block on remote calls, even if your cache
mode is synchronous.removeAsync in interface AsyncCache<K,V>removeAsync in class RemoteCacheSupport<K,V>key - key to removepublic CompletableFuture<Boolean> removeAsync(Object key, Object value)
AsyncCacheConcurrentMap.remove(Object, Object). This method does not block on remote calls, even if your
cache mode is synchronous.removeAsync in interface AsyncCache<K,V>removeAsync in class RemoteCacheSupport<K,V>key - key to removevalue - value to match onpublic CompletableFuture<V> replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
AsyncCacheBasicCache.replace(Object, Object, long, TimeUnit, long, TimeUnit). This method does not
block on remote calls, even if your cache mode is synchronous.replaceAsync in interface AsyncCache<K,V>replaceAsync in class RemoteCacheSupport<K,V>key - key to removevalue - value to storelifespan - lifespan of entrylifespanUnit - time unit for lifespanmaxIdleTime - the maximum amount of time this key is allowed to be idle for before it is considered as
expiredmaxIdleTimeUnit - time unit for max idle timepublic CompletableFuture<Boolean> containsKeyAsync(K key)
AsyncCacheMap.containsKey(Object)containsKeyAsync in interface AsyncCache<K,V>containsKeyAsync in class RemoteCacheSupport<K,V>key - key to retrievepublic boolean containsValue(Object value)
containsValue in interface Map<K,V>public CompletableFuture<Map<K,V>> getAllAsync(Set<?> keys)
AsyncCachegetAllAsync in interface AsyncCache<K,V>getAllAsync in class RemoteCacheSupport<K,V>public void start()
Lifecyclepublic void stop()
Lifecyclepublic String getName()
BasicCachegetName in interface BasicCache<K,V>public String getVersion()
BasicCachegetVersion in interface BasicCache<K,V>public String getProtocolVersion()
RemoteCachegetProtocolVersion in interface RemoteCache<K,V>public void addClientListener(Object listener)
RemoteCacheClientListener annotation.addClientListener in interface RemoteCache<K,V>public void addClientListener(Object listener, Object[] filterFactoryParams, Object[] converterFactoryParams)
RemoteCacheaddClientListener in interface RemoteCache<K,V>public void removeClientListener(Object listener)
RemoteCacheremoveClientListener in interface RemoteCache<K,V>@Deprecated public Set<Object> getListeners()
RemoteCachegetListeners in interface RemoteCache<K,V>public InternalRemoteCache<K,V> withFlags(Flag... flags)
RemoteCacheFlags to the scope of a single invocation. See the Flag enumeration to for
information on available flags.
Sample usage:
remoteCache.withFlags(Flag.FORCE_RETURN_VALUE).put("hello", "world");
withFlags in interface InternalRemoteCache<K,V>withFlags in interface RemoteCache<K,V>public CompletableFuture<V> getAsync(Object key)
AsyncCacheMap.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).getAsync in interface AsyncCache<K,V>getAsync in class RemoteCacheSupport<K,V>key - key to retrieveMap.get(Object)public PingResponse ping()
public byte[] keyToBytes(Object o)
keyToBytes in interface InternalRemoteCache<K,V>protected byte[] valueToBytes(Object o)
protected void assertRemoteCacheManagerIsStarted()
public CloseableIteratorSet<K> keySet(IntSet segments)
RemoteCacheRemoteCache.keySet() except that it will only return keys that map to the given segments.
Note that these segments will be determined by the remote server. Thus you should be aware of how many segments
it has configured and hashing algorithm it is using. If the segments and hashing algorithm are not the same
this method may return unexpected keys.keySet in interface RemoteCache<K,V>segments - the segments of keys to return - null means all availableRemoteCache.keySet()public CloseableIterator<K> keyIterator(IntSet segments)
keyIterator in interface InternalRemoteCache<K,V>public CloseableIteratorSet<Map.Entry<K,V>> entrySet(IntSet segments)
RemoteCacheRemoteCache.entrySet() except that it will only return entries that map to the given segments.
Note that these segments will be determined by the remote server. Thus you should be aware of how many segments
it has configured and hashing algorithm it is using. If the segments and hashing algorithm are not the same
this method may return unexpected entries.entrySet in interface RemoteCache<K,V>segments - the segments of entries to return - null means all availableRemoteCache.entrySet()public CloseableIterator<Map.Entry<K,V>> entryIterator(IntSet segments)
entryIterator in interface InternalRemoteCache<K,V>public CloseableIteratorCollection<V> values(IntSet segments)
RemoteCacheRemoteCache.values() except that it will only return values that map to the given segments.
Note that these segments will be determined by the remote server. Thus you should be aware of how many segments
it has configured and hashing algorithm it is using. If the segments and hashing algorithm are not the same
this method may return unexpected values.values in interface RemoteCache<K,V>segments - the segments of values to return - null means all availableRemoteCache.values()public <T> T execute(String taskName, Map<String,?> params)
RemoteCacheexecute in interface RemoteCache<K,V>public <T> T execute(String taskName, Map<String,?> params, Object key)
RemoteCacheexecute in interface RemoteCache<K,V>public CacheTopologyInfo getCacheTopologyInfo()
RemoteCacheCacheTopologyInfo for this cache.getCacheTopologyInfo in interface RemoteCache<K,V>public StreamingRemoteCache<K> streaming()
RemoteCacheInputStream and OutputStreamstreaming in interface RemoteCache<K,V>public <T,U> InternalRemoteCache<T,U> withDataFormat(DataFormat newDataFormat)
RemoteCacheRemoteCache using the supplied DataFormat.withDataFormat in interface InternalRemoteCache<K,V>withDataFormat in interface RemoteCache<K,V>public void resolveStorage(boolean objectStorage)
resolveStorage in interface InternalRemoteCache<K,V>public DataFormat getDataFormat()
RemoteCacheDataFormat being used.getDataFormat in interface RemoteCache<K,V>public boolean isTransactional()
isTransactional in interface RemoteCache<K,V>true if the cache can participate in a transaction, false otherwise.public boolean isObjectStorage()
isObjectStorage in interface InternalRemoteCache<K,V>public boolean hasForceReturnFlag()
hasForceReturnFlag in interface InternalRemoteCache<K,V>Copyright © 2021 JBoss by Red Hat. All rights reserved.