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>

Author:

Manik Surtani, Mircea.Markus@jboss.com, Pete Muir, Dan Berindei <dan@infinispan.org>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReadOnlyManyHelper()

Method Summary

Modifier and Type	Method	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 Object

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

Methods inherited from interface InvocationSuccessFunction

apply

Constructor Details

ReadOnlyManyHelper

protected ReadOnlyManyHelper()

Method Details

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>