org.infinispan.remoting.inboundhandler

Class AbstractDelegatingHandler

java.lang.Object

org.infinispan.remoting.inboundhandler.AbstractDelegatingHandler

All Implemented Interfaces:

JmxStatisticsExposer, PerCacheInboundInvocationHandler

public abstract class AbstractDelegatingHandler
extends Object
implements PerCacheInboundInvocationHandler

Class to be extended to allow some control over the PerCacheInboundInvocationHandler in tests.

Since:

7.1

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field and Description
protected PerCacheInboundInvocationHandler	delegate

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDelegatingHandler(PerCacheInboundInvocationHandler delegate)

Method Summary

Modifier and Type	Method and Description
protected void	afterHandle(CacheRpcCommand command, DeliverOrder order, boolean delegated) Invoked after the command is handled.
protected boolean	beforeHandle(CacheRpcCommand command, Reply reply, DeliverOrder order) Invoked before the command is handled by the real PerCacheInboundInvocationHandler.
void	checkForReadyTasks() Checks if any pending tasks are now ready to be ran and will run in them in a separate thread.
int	getFirstTopologyAsMember()
boolean	getStatisticsEnabled() Returns whether an interceptor's statistics are being captured.
void	handle(CacheRpcCommand command, Reply reply, DeliverOrder order) Handles the CacheRpcCommand from other node.
void	registerXSiteCommandReceiver()
void	resetStatistics() Resets an interceptor's cache statistics
void	setFirstTopologyAsMember(int firstTopologyAsMember)
void	setStatisticsEnabled(boolean enabled) Enables an interceptor's cache statistics If true, the interceptor will capture statistics and make them available through the mbean.

Methods inherited from class java.lang.Object

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

Field Detail

delegate

protected final PerCacheInboundInvocationHandler delegate

Constructor Detail

AbstractDelegatingHandler

protected AbstractDelegatingHandler(PerCacheInboundInvocationHandler delegate)

Method Detail

handle

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

Description copied from interface: PerCacheInboundInvocationHandler

Handles the CacheRpcCommand from other node.

Specified by:

handle in interface PerCacheInboundInvocationHandler

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

public void setFirstTopologyAsMember(int firstTopologyAsMember)

Specified by:

setFirstTopologyAsMember in interface PerCacheInboundInvocationHandler

Parameters:

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

getFirstTopologyAsMember

public int getFirstTopologyAsMember()

Specified by:

getFirstTopologyAsMember in interface PerCacheInboundInvocationHandler

Returns:

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

beforeHandle

protected boolean beforeHandle(CacheRpcCommand command,
                               Reply reply,
                               DeliverOrder order)

Invoked before the command is handled by the real PerCacheInboundInvocationHandler.

Returns:

true if the command should be handled by the read PerCacheInboundInvocationHandler, false otherwise.

afterHandle

protected void afterHandle(CacheRpcCommand command,
                           DeliverOrder order,
                           boolean delegated)

Invoked after the command is handled.

Parameters:

delegated - true if the command was handled by the real PerCacheInboundInvocationHandler, false otherwise.

registerXSiteCommandReceiver

public void registerXSiteCommandReceiver()

Specified by:

registerXSiteCommandReceiver in interface PerCacheInboundInvocationHandler

getStatisticsEnabled

public boolean getStatisticsEnabled()

Description copied from interface: JmxStatisticsExposer

Returns whether an interceptor's statistics are being captured.

Specified by:

getStatisticsEnabled in interface JmxStatisticsExposer

Returns:

true if statistics are captured

setStatisticsEnabled

public void setStatisticsEnabled(boolean enabled)

Description copied from interface: JmxStatisticsExposer

Enables an interceptor's cache statistics If true, the interceptor will capture statistics and make them available through the mbean.

Specified by:

setStatisticsEnabled in interface JmxStatisticsExposer

Parameters:

enabled - true if statistics should be captured

resetStatistics

public void resetStatistics()

Description copied from interface: JmxStatisticsExposer

Resets an interceptor's cache statistics

Specified by:

resetStatistics in interface JmxStatisticsExposer

checkForReadyTasks

public void checkForReadyTasks()

Description copied from interface: PerCacheInboundInvocationHandler

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.

Specified by:

checkForReadyTasks in interface PerCacheInboundInvocationHandler