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	applyState(String cacheName, InputStream i) Applies state onto a named cache.
void	generateState(String cacheName, OutputStream o) Generates state from a named cache.
Response	handle(CacheRpcCommand cmd) Invokes a command on the cache, from a remote source.
void	inject(GlobalComponentRegistry gcr, StreamingMarshaller marshaller)

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,
                   StreamingMarshaller marshaller)

handle

public Response handle(CacheRpcCommand cmd)
                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

Returns:

results, if any, from the invocation

Throws:

Throwable - in the event of problems executing the command

applyState

public void applyState(String cacheName,
                       InputStream i)
                throws StateTransferException

Description copied from interface: InboundInvocationHandler

Applies state onto a named cache. State to be read from the stream. Implementations should NOT close the stream after use.

Specified by:

applyState in interface InboundInvocationHandler

Parameters:

cacheName - name of cache to apply state

i - stream to read from

Throws:

StateTransferException - in the event of problems

generateState

public void generateState(String cacheName,
                          OutputStream o)
                   throws StateTransferException

Description copied from interface: InboundInvocationHandler

Generates state from a named cache. State to be written to the stream. Implementations should NOT close the stream after use.

Specified by:

generateState in interface InboundInvocationHandler

Parameters:

cacheName - name of cache from which to generate state

o - stream to write state to

Throws:

StateTransferException - in the event of problems