org.infinispan.interceptors.distribution

Class BaseDistributionInterceptor.ReadOnlyManyHelper

java.lang.Object

org.infinispan.interceptors.distribution.BaseDistributionInterceptor.ReadOnlyManyHelper

All Implemented Interfaces:

BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>, InvocationCallback<ReadOnlyManyCommand>, InvocationSuccessFunction<ReadOnlyManyCommand>

Enclosing class:

BaseDistributionInterceptor

protected class BaseDistributionInterceptor.ReadOnlyManyHelper
extends Object
implements BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ReadOnlyManyHelper()

Method Summary

Modifier and Type	Method and Description
Object	apply(InvocationContext rCtx, ReadOnlyManyCommand rCommand, Object rv) Process the result from a successful invocation stage and either return a simple value, return a new InvocationStage, or throw an exception.
void	applyLocalResult(org.infinispan.interceptors.distribution.MergingCompletableFuture allFuture, Object rv)
ReadOnlyManyCommand	copyForLocal(ReadOnlyManyCommand command, List<Object> keys)
ReadOnlyManyCommand	copyForRemote(ReadOnlyManyCommand command, List<Object> keys, InvocationContext ctx)
CompletionStage<Void>	fetchRequiredKeys(LocalizedCacheTopology cacheTopology, Map<Address,List<Object>> requestedKeys, List<Object> availableKeys, InvocationContext ctx, ReadOnlyManyCommand command)
Collection<?>	keys(ReadOnlyManyCommand command)
Object	transformResult(Object[] results)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.interceptors.InvocationSuccessFunction

apply

Constructor Detail

ReadOnlyManyHelper

protected ReadOnlyManyHelper()

Method Detail

apply

public Object apply(InvocationContext rCtx,
                    ReadOnlyManyCommand rCommand,
                    Object rv)
             throws Throwable

Description copied from interface: InvocationSuccessFunction

Process the result from a successful invocation stage and either return a simple value, return a new InvocationStage, or throw an exception.

Specified by:

apply in interface InvocationSuccessFunction<ReadOnlyManyCommand>

Throws:

Throwable

keys

public Collection<?> keys(ReadOnlyManyCommand command)

Specified by:

keys in interface BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>

copyForLocal

public ReadOnlyManyCommand copyForLocal(ReadOnlyManyCommand command,
                                        List<Object> keys)

Specified by:

copyForLocal in interface BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>

copyForRemote

public ReadOnlyManyCommand copyForRemote(ReadOnlyManyCommand command,
                                         List<Object> keys,
                                         InvocationContext ctx)

Specified by:

copyForRemote in interface BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>

applyLocalResult

public void applyLocalResult(org.infinispan.interceptors.distribution.MergingCompletableFuture allFuture,
                             Object rv)

Specified by:

applyLocalResult in interface BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>

transformResult

public Object transformResult(Object[] results)

Specified by:

transformResult in interface BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>

fetchRequiredKeys

public CompletionStage<Void> fetchRequiredKeys(LocalizedCacheTopology cacheTopology,
                                               Map<Address,List<Object>> requestedKeys,
                                               List<Object> availableKeys,
                                               InvocationContext ctx,
                                               ReadOnlyManyCommand command)

Specified by:

fetchRequiredKeys in interface BaseDistributionInterceptor.ReadManyCommandHelper<ReadOnlyManyCommand>