org.infinispan.remoting.inboundhandler

Interface PerCacheInboundInvocationHandler

All Superinterfaces:

JmxStatisticsExposer

All Known Implementing Classes:

AbstractDelegatingHandler, BasePerCacheInboundInvocationHandler, NonTxPerCacheInboundInvocationHandler, TrianglePerCacheInboundInvocationHandler, TxPerCacheInboundInvocationHandler

public interface PerCacheInboundInvocationHandler
extends JmxStatisticsExposer

Interface to invoke when a CacheRpcCommand is received from other node in the local site.

Since:

7.1

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method and Description
void	checkForReadyTasks() Checks if any pending tasks are now ready to be ran and will run in them in a separate thread.
int	getFirstTopologyAsMember()
void	handle(CacheRpcCommand command, Reply reply, DeliverOrder order) Handles the CacheRpcCommand from other node.
void	registerXSiteCommandReceiver()
void	setFirstTopologyAsMember(int firstTopologyAsMember)

Methods inherited from interface org.infinispan.jmx.JmxStatisticsExposer

getStatisticsEnabled, resetStatistics, setStatisticsEnabled

Method Detail

handle

void handle(CacheRpcCommand command,
            Reply reply,
            DeliverOrder order)

Handles the CacheRpcCommand from other node.

Parameters:

command - the CacheRpcCommand to handle.

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

order - the DeliverOrder in which the command was sent

setFirstTopologyAsMember

void setFirstTopologyAsMember(int firstTopologyAsMember)

Parameters:

firstTopologyAsMember - The first topology in which the local node was a member. Any command with a lower topology id will be ignored.

getFirstTopologyAsMember

int getFirstTopologyAsMember()

Returns:

The first topology in which the local node was a member. Any command with a lower topology id will be ignored.

registerXSiteCommandReceiver

void registerXSiteCommandReceiver()

checkForReadyTasks

void checkForReadyTasks()

Checks if any pending tasks are now ready to be ran and will run in them in a separate thread. This method does not block.