Package org.infinispan.remoting.inboundhandler

Class BasePerCacheInboundInvocationHandler

java.lang.Object

org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler

All Implemented Interfaces:

JmxStatisticsExposer, PerCacheInboundInvocationHandler

Direct Known Subclasses:

NonTotalOrderPerCacheInboundInvocationHandler, NonTotalOrderTxPerCacheInboundInvocationHandler, TotalOrderTxPerCacheInboundInvocationHandler, TrianglePerCacheInboundInvocationHandler

public abstract class BasePerCacheInboundInvocationHandler
extends java.lang.Object
implements PerCacheInboundInvocationHandler

Implementation with the default handling methods and utilities methods.

Since:

7.1

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field	Description
protected Configuration	configuration
static java.lang.String	MBEAN_COMPONENT_NAME
protected BlockingTaskAwareExecutorService	remoteCommandsExecutor

Constructor Summary

Constructors

Constructor	Description
BasePerCacheInboundInvocationHandler()

Method Summary

Modifier and Type	Method	Description
long	getAsyncXSiteRequestsReceived()
int	getFirstTopologyAsMember()
protected abstract org.infinispan.util.logging.Log	getLog()
boolean	getStatisticsEnabled()	Returns whether an interceptor's statistics are being captured.
long	getSyncXSiteRequestsReceived()
boolean	isCommandSentBeforeFirstTopology(int commandTopologyId)
boolean	isStatisticsEnabled()
boolean	isStopped()
protected abstract boolean	isTraceEnabled()
void	registerXSiteCommandReceiver(boolean sync)
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.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.remoting.inboundhandler.PerCacheInboundInvocationHandler

handle

Field Detail

MBEAN_COMPONENT_NAME

public static final java.lang.String MBEAN_COMPONENT_NAME

See Also:

Constant Field Values

remoteCommandsExecutor

protected BlockingTaskAwareExecutorService remoteCommandsExecutor

configuration

protected Configuration configuration

Constructor Detail

BasePerCacheInboundInvocationHandler

public BasePerCacheInboundInvocationHandler()

Method Detail

start

public void start()

stop

public void stop()

isStopped

public boolean isStopped()

isCommandSentBeforeFirstTopology

public final boolean isCommandSentBeforeFirstTopology(int commandTopologyId)

getLog

protected abstract org.infinispan.util.logging.Log getLog()

isTraceEnabled

protected abstract boolean isTraceEnabled()

registerXSiteCommandReceiver

public void registerXSiteCommandReceiver(boolean sync)

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

resetStatistics

public void resetStatistics()

Description copied from interface: JmxStatisticsExposer

Resets an interceptor's cache statistics

Specified by:

resetStatistics in interface JmxStatisticsExposer

isStatisticsEnabled

public boolean isStatisticsEnabled()

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

getSyncXSiteRequestsReceived

public long getSyncXSiteRequestsReceived()

getAsyncXSiteRequestsReceived

public long getAsyncXSiteRequestsReceived()

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.