com.mulesoft.mule.runtime.module.cluster.internal

Class HazelcastClusterLocker

java.lang.Object

java.lang.Thread

com.mulesoft.mule.runtime.module.cluster.internal.HazelcastClusterLocker

All Implemented Interfaces:

ClusterLocker, Runnable

public class HazelcastClusterLocker
extends Thread
implements ClusterLocker

Blocks until can acquires a lock on a Hazelcast's ILock.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	PRIMARY_SERVER_LOCK_ID

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
HazelcastClusterLocker(String lockId, com.hazelcast.core.HazelcastInstance hazelcastInstance, PrimaryClusterNodeNotifier primaryClusterNodeNotifier, int heartbeatTimeoutSecs) Creates a new instance to acquire a lock

Method Summary

Modifier and Type	Method and Description
com.hazelcast.core.ILock	getLock()
void	notifyIfPollingNode() Provides a way to synchronize the access to the cluster lock.
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

PRIMARY_SERVER_LOCK_ID

public static final String PRIMARY_SERVER_LOCK_ID

See Also:

Constant Field Values

Constructor Detail

HazelcastClusterLocker

public HazelcastClusterLocker(String lockId,
                              com.hazelcast.core.HazelcastInstance hazelcastInstance,
                              PrimaryClusterNodeNotifier primaryClusterNodeNotifier,
                              int heartbeatTimeoutSecs)

Creates a new instance to acquire a lock

Parameters:

lockId - the id of the lock to be acquired

hazelcastInstance - the hazelcast instance used to acquire the lock

primaryClusterNodeNotifier - used to notify the acquisition of the lock

heartbeatTimeoutSecs - the value of the heartbeat timeout as configured in Hazelcast

Method Detail

notifyIfPollingNode

public void notifyIfPollingNode()

Description copied from interface: ClusterLocker

Provides a way to synchronize the access to the cluster lock.

The node that gets access to the cluster lock will become the primary node in the cluster.

Specified by:

notifyIfPollingNode in interface ClusterLocker

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

getLock

public com.hazelcast.core.ILock getLock()