org.infinispan.remoting.inboundhandler

Class GlobalInboundInvocationHandler

java.lang.Object

org.infinispan.remoting.inboundhandler.GlobalInboundInvocationHandler

All Implemented Interfaces:

InboundInvocationHandler

public class GlobalInboundInvocationHandler
extends Object
implements InboundInvocationHandler

InboundInvocationHandler implementation that handles all the ReplicableCommand.

This component handles the ReplicableCommand from local and remote site. The remote site ReplicableCommand are sent to the BackupReceiver to be handled.

Also, the non-CacheRpcCommand are processed directly and the CacheRpcCommand are processed in the cache's PerCacheInboundInvocationHandler implementation.

Since:

7.1

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor and Description
GlobalInboundInvocationHandler()

Method Summary

Modifier and Type	Method and Description
void	cacheStopped(CacheStoppedEvent event)
ByteString	getLocalCacheForRemoteSite(String remoteSite, ByteString remoteCache) test only! See BackupCacheStoppedTest
void	handleFromCluster(Address origin, ReplicableCommand command, Reply reply, DeliverOrder order) Handles the ReplicableCommand from other node belonging to local site.
void	handleFromRemoteSite(String origin, XSiteReplicateCommand command, Reply reply, DeliverOrder order) Handles the ReplicableCommand from remote site.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalInboundInvocationHandler

public GlobalInboundInvocationHandler()

Method Detail

start

public void start()

stop

public void stop()

cacheStopped

public void cacheStopped(CacheStoppedEvent event)

handleFromCluster

public void handleFromCluster(Address origin,
                              ReplicableCommand command,
                              Reply reply,
                              DeliverOrder order)

Description copied from interface: InboundInvocationHandler

Handles the ReplicableCommand from other node belonging to local site.

Specified by:

handleFromCluster in interface InboundInvocationHandler

Parameters:

origin - the sender Address

command - the ReplicableCommand to handler

reply - the return value is passed to this object in order to be sent back to the origin

order - the DeliverOrder in which the command was sent

handleFromRemoteSite

public void handleFromRemoteSite(String origin,
                                 XSiteReplicateCommand command,
                                 Reply reply,
                                 DeliverOrder order)

Description copied from interface: InboundInvocationHandler

Handles the ReplicableCommand from remote site.

Specified by:

handleFromRemoteSite in interface InboundInvocationHandler

Parameters:

origin - the sender site

command - the ReplicableCommand to handle

reply - the return value is passed to this object in order to be sent back to the origin

order - the DeliverOrder in which the command was sent

getLocalCacheForRemoteSite

public ByteString getLocalCacheForRemoteSite(String remoteSite,
                                             ByteString remoteCache)

test only! See BackupCacheStoppedTest