Package org.infinispan.remoting

Class LocalInvocation

java.lang.Object

org.infinispan.remoting.LocalInvocation

All Implemented Interfaces:

Callable<Response>, Function<Object,Response>

public class LocalInvocation
extends Object
implements Callable<Response>, Function<Object,Response>

Simulates a remote invocation on the local node. This is needed because the transport does not redirect to itself the replicable commands.

Since:

7.0

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method	Description
Response	apply(Object retVal)
Response	call()
CompletableFuture<Response>	callAsync()
boolean	equals(Object o)
int	hashCode()
static LocalInvocation	newInstance(ResponseGenerator responseGenerator, org.infinispan.commands.remote.CacheRpcCommand command, org.infinispan.commands.CommandsFactory commandsFactory, Address self)
static LocalInvocation	newInstanceFromCache(Cache<?,?> cache, org.infinispan.commands.remote.CacheRpcCommand command)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Method Detail

call

public Response call()
              throws Exception

Specified by:

call in interface Callable<Response>

Throws:

Exception

newInstanceFromCache

public static LocalInvocation newInstanceFromCache(Cache<?,?> cache,
                                                   org.infinispan.commands.remote.CacheRpcCommand command)

newInstance

public static LocalInvocation newInstance(ResponseGenerator responseGenerator,
                                          org.infinispan.commands.remote.CacheRpcCommand command,
                                          org.infinispan.commands.CommandsFactory commandsFactory,
                                          Address self)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

callAsync

public CompletableFuture<Response> callAsync()

apply

public Response apply(Object retVal)

Specified by:

apply in interface Function<Object,Response>