org.infinispan.remoting.inboundhandler

Class BasePerCacheInboundInvocationHandler

java.lang.Object

org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler

All Implemented Interfaces:

JmxStatisticsExposer, PerCacheInboundInvocationHandler

Direct Known Subclasses:

NonTxPerCacheInboundInvocationHandler, TrianglePerCacheInboundInvocationHandler, TxPerCacheInboundInvocationHandler

@MBean(objectName="InboundInvocationHandler",
       description="Handles all the remote requests.")
public abstract class BasePerCacheInboundInvocationHandler
extends 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 and Description
protected BlockingTaskAwareExecutorService	blockingExecutor
protected Configuration	configuration
static String	MBEAN_COMPONENT_NAME
protected BlockingTaskAwareExecutorService	nonBlockingExecutor

Constructor Summary

Constructors

Constructor and Description
BasePerCacheInboundInvocationHandler()

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()
protected abstract Log	getLog()
boolean	getStatisticsEnabled() Returns whether an interceptor's statistics are being captured.
long	getXSiteRequestsReceived()
boolean	isCommandSentBeforeFirstTopology(int commandTopologyId)
boolean	isStatisticsEnabled()
boolean	isStopped()
protected abstract boolean	isTraceEnabled()
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.
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 String MBEAN_COMPONENT_NAME

See Also:

Constant Field Values

blockingExecutor

protected BlockingTaskAwareExecutorService blockingExecutor

nonBlockingExecutor

protected BlockingTaskAwareExecutorService nonBlockingExecutor

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 Log getLog()

isTraceEnabled

protected abstract boolean isTraceEnabled()

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

resetStatistics

@ManagedOperation(description="Resets statistics gathered by this component",
                  displayName="Reset statistics")
public void resetStatistics()

Description copied from interface: JmxStatisticsExposer

Resets an interceptor's cache statistics

Specified by:

resetStatistics in interface JmxStatisticsExposer

isStatisticsEnabled

@ManagedAttribute(description="Enables or disables the gathering of statistics by this component",
                  displayName="Statistics enabled",
                  dataType=TRAIT,
                  writable=true)
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

getXSiteRequestsReceived

@ManagedAttribute(description="Returns the number of cross-site requests received by this node",
                  displayName="Cross-Site Requests Received")
public long getXSiteRequestsReceived()

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.

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