org.apache.ignite.internal.worker

Class FailureHandlingMxBeanImpl

java.lang.Object

org.apache.ignite.internal.worker.FailureHandlingMxBeanImpl

All Implemented Interfaces:

FailureHandlingMxBean

public class FailureHandlingMxBeanImpl
extends Object
implements FailureHandlingMxBean

Constructor Summary

Constructors

Constructor and Description
FailureHandlingMxBeanImpl(@NotNull WorkersRegistry workersRegistry, @NotNull IgniteCacheDatabaseSharedManager dbMgr)

Method Summary

Modifier and Type	Method and Description
long	getCheckpointReadLockTimeout()
boolean	getLivenessCheckEnabled()
long	getSystemWorkerBlockedTimeout()
void	setCheckpointReadLockTimeout(long val)
void	setLivenessCheckEnabled(boolean val)
void	setSystemWorkerBlockedTimeout(long val)

Methods inherited from class java.lang.Object

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

Constructor Detail

FailureHandlingMxBeanImpl

public FailureHandlingMxBeanImpl(@NotNull
                                 @NotNull WorkersRegistry workersRegistry,
                                 @NotNull
                                 @NotNull IgniteCacheDatabaseSharedManager dbMgr)

Parameters:

workersRegistry - Workers registry.

dbMgr - Database manager.

Method Detail

getLivenessCheckEnabled

public boolean getLivenessCheckEnabled()

Specified by:

getLivenessCheckEnabled in interface FailureHandlingMxBean

setLivenessCheckEnabled

public void setLivenessCheckEnabled(boolean val)

Specified by:

setLivenessCheckEnabled in interface FailureHandlingMxBean

getSystemWorkerBlockedTimeout

public long getSystemWorkerBlockedTimeout()

Specified by:

getSystemWorkerBlockedTimeout in interface FailureHandlingMxBean

setSystemWorkerBlockedTimeout

public void setSystemWorkerBlockedTimeout(long val)

Specified by:

setSystemWorkerBlockedTimeout in interface FailureHandlingMxBean

getCheckpointReadLockTimeout

public long getCheckpointReadLockTimeout()

Specified by:

getCheckpointReadLockTimeout in interface FailureHandlingMxBean

setCheckpointReadLockTimeout

public void setCheckpointReadLockTimeout(long val)

Specified by:

setCheckpointReadLockTimeout in interface FailureHandlingMxBean