Package org.infinispan.interceptors.distribution

Class BaseDistributionInterceptor.ReadOnlyManyHelper

java.lang.Object

org.infinispan.interceptors.distribution.BaseDistributionInterceptor.ReadOnlyManyHelper

All Implemented Interfaces:

BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>, InvocationCallback, InvocationSuccessFunction

Enclosing class:

BaseDistributionInterceptor

protected class BaseDistributionInterceptor.ReadOnlyManyHelper
extends Object
implements BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReadOnlyManyHelper()

Method Summary

Modifier and Type	Method	Description
Object	apply(InvocationContext rCtx, VisitableCommand 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)
org.infinispan.commands.functional.ReadOnlyManyCommand	copyForLocal(org.infinispan.commands.functional.ReadOnlyManyCommand command, List<Object> keys)
org.infinispan.commands.functional.ReadOnlyManyCommand	copyForRemote(org.infinispan.commands.functional.ReadOnlyManyCommand command, List<Object> keys, InvocationContext ctx)
CompletionStage<Void>	fetchRequiredKeys(LocalizedCacheTopology cacheTopology, Map<Address,List<Object>> requestedKeys, List<Object> availableKeys, InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyManyCommand command)
Collection<?>	keys(org.infinispan.commands.functional.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,
                    VisitableCommand 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

Throws:

Throwable

keys

public Collection<?> keys(org.infinispan.commands.functional.ReadOnlyManyCommand command)

Specified by:

keys in interface BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>

copyForLocal

public org.infinispan.commands.functional.ReadOnlyManyCommand copyForLocal(org.infinispan.commands.functional.ReadOnlyManyCommand command,
                                                                           List<Object> keys)

Specified by:

copyForLocal in interface BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>

copyForRemote

public org.infinispan.commands.functional.ReadOnlyManyCommand copyForRemote(org.infinispan.commands.functional.ReadOnlyManyCommand command,
                                                                            List<Object> keys,
                                                                            InvocationContext ctx)

Specified by:

copyForRemote in interface BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>

applyLocalResult

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

Specified by:

applyLocalResult in interface BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>

transformResult

public Object transformResult(Object[] results)

Specified by:

transformResult in interface BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>

fetchRequiredKeys

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

Specified by:

fetchRequiredKeys in interface BaseDistributionInterceptor.ReadManyCommandHelper<org.infinispan.commands.functional.ReadOnlyManyCommand>