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 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 String	MBEAN_COMPONENT_NAME
protected BlockingTaskAwareExecutorService	remoteCommandsExecutor

Constructor Summary

Constructors

Constructor	Description
BasePerCacheInboundInvocationHandler()

Method Summary

Modifier and Type	Method	Description
long	getAsyncXSitePendingRequests()
long	getAsyncXSiteRequestQueueTime()
long	getAsyncXSiteRequestRunningTime()
long	getAsyncXSiteRequestsReceived()
long	getAsyncXSiteRunningRequests()
int	getFirstTopologyAsMember()
protected abstract 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	registerXSiteActionSequencer(ActionSequencer sequencer)	Registers the ActionSequencer used by async cross-site requests to expose some internals metrics.
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 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()

registerXSiteActionSequencer

public void registerXSiteActionSequencer(ActionSequencer sequencer)

Description copied from interface: PerCacheInboundInvocationHandler

Registers the ActionSequencer used by async cross-site requests to expose some internals metrics.

Specified by:

registerXSiteActionSequencer in interface PerCacheInboundInvocationHandler

isCommandSentBeforeFirstTopology

public final boolean isCommandSentBeforeFirstTopology(int commandTopologyId)

getLog

protected abstract 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()

getAsyncXSitePendingRequests

public long getAsyncXSitePendingRequests()

getAsyncXSiteRunningRequests

public long getAsyncXSiteRunningRequests()

getAsyncXSiteRequestQueueTime

public long getAsyncXSiteRequestQueueTime()

getAsyncXSiteRequestRunningTime

public long getAsyncXSiteRequestRunningTime()

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.