|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.infinispan.remoting.InboundInvocationHandlerImpl
public class InboundInvocationHandlerImpl
Sets the cache interceptor chain on an RPCCommand before calling it to perform
| Constructor Summary | |
|---|---|
InboundInvocationHandlerImpl()
|
|
| Method Summary | |
|---|---|
void |
applyState(String cacheName,
InputStream i)
Applies state onto a named cache. |
void |
blockTillNoLongerRetrying(String cacheName)
Calling this method should block if the invocation handler implementation has been queueing commands for a given named cache and is in the process of flushing this queue. |
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. |
org.infinispan.remoting.InboundInvocationHandlerImpl.JoinHandle |
howToHandle(CacheRpcCommand cmd)
|
void |
inject(GlobalComponentRegistry gcr,
StreamingMarshaller marshaller,
EmbeddedCacheManager embeddedCacheManager,
Transport transport,
GlobalConfiguration globalConfiguration)
|
void |
start()
|
void |
waitForStart(CacheRpcCommand cmd)
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public InboundInvocationHandlerImpl()
| Method Detail |
|---|
public void inject(GlobalComponentRegistry gcr,
StreamingMarshaller marshaller,
EmbeddedCacheManager embeddedCacheManager,
Transport transport,
GlobalConfiguration globalConfiguration)
public void start()
public void waitForStart(CacheRpcCommand cmd)
public Response handle(CacheRpcCommand cmd)
throws Throwable
InboundInvocationHandler
handle in interface InboundInvocationHandlercmd - command to invoke
Throwable - in the event of problems executing the commandpublic org.infinispan.remoting.InboundInvocationHandlerImpl.JoinHandle howToHandle(CacheRpcCommand cmd)
public void applyState(String cacheName,
InputStream i)
throws StateTransferException
InboundInvocationHandler
applyState in interface InboundInvocationHandlercacheName - name of cache to apply statei - stream to read from
StateTransferException - in the event of problems
public void generateState(String cacheName,
OutputStream o)
throws StateTransferException
InboundInvocationHandler
generateState in interface InboundInvocationHandlercacheName - name of cache from which to generate stateo - stream to write state to
StateTransferException - in the event of problemspublic void blockTillNoLongerRetrying(String cacheName)
InboundInvocationHandler
blockTillNoLongerRetrying in interface InboundInvocationHandlercacheName - name of the cache for which the handler would be queueing requests.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||