org.infinispan.distexec
Interface DistributedCallable<K,V,T>

All Superinterfaces:

Callable<T>

public interface DistributedCallable<K,V,T>
extends Callable<T>

A task that returns a result and may throw an exception capable of being executed in another JVM.

Since:

5.0

Author:

Manik Surtani, Vladimir Blagojevic

See Also:

Callable

Method Summary

void	setEnvironment(Cache<K,V> cache, Set<K> inputKeys) Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.

Methods inherited from interface java.util.concurrent.Callable

call

Method Detail

setEnvironment

void setEnvironment(Cache<K,V> cache,
                    Set<K> inputKeys)

Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.

Parameters:

cache - cache whose keys are used as input data for this DistributedCallable task

inputKeys - keys used as input for this DistributedCallable task