org.infinispan.remoting
Class InboundInvocationHandlerImpl

java.lang.Object
  org.infinispan.remoting.InboundInvocationHandlerImpl

All Implemented Interfaces:

InboundInvocationHandler

public class InboundInvocationHandlerImpl
extends Object
implements InboundInvocationHandler

Sets the cache interceptor chain on an RPCCommand before calling it to perform

Since:

4.0

Author:

Manik Surtani

Constructor Summary

InboundInvocationHandlerImpl()

Method Summary

void	handle(CacheRpcCommand cmd, Address origin, org.jgroups.blocks.Response response, boolean preserveOrder) Invokes a command on the cache, from a remote source.
void	inject(GlobalComponentRegistry gcr, Transport transport, ExecutorService remoteCommandsExecutor, BlockingTaskAwareExecutorService totalOrderExecutorService, GlobalConfiguration globalConfiguration, CancellationService cancelService)

Methods inherited from class java.lang.Object

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

Constructor Detail

InboundInvocationHandlerImpl

public InboundInvocationHandlerImpl()

Method Detail

inject

public void inject(GlobalComponentRegistry gcr,
                   Transport transport,
                   ExecutorService remoteCommandsExecutor,
                   BlockingTaskAwareExecutorService totalOrderExecutorService,
                   GlobalConfiguration globalConfiguration,
                   CancellationService cancelService)

handle

public void handle(CacheRpcCommand cmd,
                   Address origin,
                   org.jgroups.blocks.Response response,
                   boolean preserveOrder)
            throws Throwable

Description copied from interface: InboundInvocationHandler

Invokes a command on the cache, from a remote source.

Specified by:

handle in interface InboundInvocationHandler

Parameters:

cmd - command to invoke

response - the asynchronous request reference from org.infinispan.remoting.transport.Transport. A null value means that the request does not expect a return value.

Throws:

Throwable - in the event of problems executing the command