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

Class HazelcastClusterManager

java.lang.Object

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

All Implemented Interfaces:

ClusterManager, PrimaryClusterNodeListener

public class HazelcastClusterManager
extends Object
implements ClusterManager

This class manages the connection to the Hazelcast spaces used to implement clustering.

This class it is registered as an Object in each MuleContext so it can be used by Cluster Mule Component. Thus this class cannot implement any lifecycle phase.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clusterId

Fields inherited from interface com.mulesoft.mule.runtime.module.cluster.api.ClusterManager

CLUSTER_MANAGER_ID

Method Summary

Modifier and Type	Method and Description
static HazelcastClusterManager	create(org.mule.runtime.module.artifact.api.classloader.ClassLoaderRepository classLoaderRepository)
static com.hazelcast.core.MembershipListener	createConnectionListener(ClusterManager manager)
static HazelcastClusterManager	createManager(org.mule.runtime.module.artifact.api.classloader.ClassLoaderRepository classLoaderRepository)
static HazelcastClusterLocker	createPrimaryNodePollingThread(HazelcastClusterManager hazelcastManager, CompositePrimaryClusterNodeNotifier clusterPrimaryNodeNotifier, int heartbeatTimeoutSecs)
void	dispose()
Properties	getClusterConfigProperties()
String	getClusterId()
String	getClusterNodeId()
static String	getClusterPoolingLockId(String clusterId)
ClusterStoreProfile	getDefaultClusterStoreProfile()
com.hazelcast.core.HazelcastInstance	getHazelcastInstance()
ClusterLocker	getPrimaryNodePollingThread()
InetSocketAddress	getSocketAddress()
ConcurrentMap<String,Object>	getUserContext()
void	initialise()
boolean	isClientModeEnabled()
static boolean	isDuplicateHazelCastServerInstanceRequested()
boolean	isPrimaryPollingInstance()
void	onNotification()
void	registerObjectStore(HazelcastObjectStore store)
void	registerPrimaryNodeListener(PrimaryClusterNodeListener primaryClusterNodeListener)
void	setAsPollingNode(boolean isPoller) Configures the polling status of the current cluster node.
void	shutdown() Terminates the cluster gracefully waiting for operations to be completed.
int	size()
void	terminate() Terminates the cluster ungracefully forcing immediate shutdown.
void	unregisterObjectStore(HazelcastObjectStore store)
void	unregisterPrimaryNodeListener(PrimaryClusterNodeListener primaryClusterNodeListener)

Methods inherited from class java.lang.Object

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

Field Detail

clusterId

protected String clusterId

Method Detail

getClusterConfigProperties

public Properties getClusterConfigProperties()

setAsPollingNode

public void setAsPollingNode(boolean isPoller)

Description copied from interface: ClusterManager

Configures the polling status of the current cluster node.

Specified by:

setAsPollingNode in interface ClusterManager

Parameters:

isPoller - true if the node must poll, false otherwise.

getPrimaryNodePollingThread

public ClusterLocker getPrimaryNodePollingThread()

Specified by:

getPrimaryNodePollingThread in interface ClusterManager

Returns:

the ClusterLocker for the cluster node.

createConnectionListener

public static com.hazelcast.core.MembershipListener createConnectionListener(ClusterManager manager)

createManager

public static HazelcastClusterManager createManager(org.mule.runtime.module.artifact.api.classloader.ClassLoaderRepository classLoaderRepository)

isDuplicateHazelCastServerInstanceRequested

public static boolean isDuplicateHazelCastServerInstanceRequested()

create

public static HazelcastClusterManager create(org.mule.runtime.module.artifact.api.classloader.ClassLoaderRepository classLoaderRepository)
                                      throws org.mule.runtime.api.lifecycle.InitialisationException

Throws:

org.mule.runtime.api.lifecycle.InitialisationException

isClientModeEnabled

public boolean isClientModeEnabled()

Specified by:

isClientModeEnabled in interface ClusterManager

Returns:

whether is client mode enabled

getClusterId

public String getClusterId()

Specified by:

getClusterId in interface ClusterManager

Returns:

the cluster identifier

getClusterNodeId

public String getClusterNodeId()

Specified by:

getClusterNodeId in interface ClusterManager

Returns:

the cluster's node identifier

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

getUserContext

public ConcurrentMap<String,Object> getUserContext()

registerObjectStore

public void registerObjectStore(HazelcastObjectStore store)

unregisterObjectStore

public void unregisterObjectStore(HazelcastObjectStore store)

initialise

public void initialise()
                throws org.mule.runtime.api.exception.MuleException

Throws:

org.mule.runtime.api.exception.MuleException

dispose

public void dispose()

isPrimaryPollingInstance

public boolean isPrimaryPollingInstance()

Specified by:

isPrimaryPollingInstance in interface ClusterManager

Returns:

true is the current cluster node is the primary one, false otherwise.

onNotification

public void onNotification()

Specified by:

onNotification in interface PrimaryClusterNodeListener

createPrimaryNodePollingThread

public static HazelcastClusterLocker createPrimaryNodePollingThread(HazelcastClusterManager hazelcastManager,
                                                                    CompositePrimaryClusterNodeNotifier clusterPrimaryNodeNotifier,
                                                                    int heartbeatTimeoutSecs)

getClusterPoolingLockId

public static String getClusterPoolingLockId(String clusterId)

unregisterPrimaryNodeListener

public void unregisterPrimaryNodeListener(PrimaryClusterNodeListener primaryClusterNodeListener)

registerPrimaryNodeListener

public void registerPrimaryNodeListener(PrimaryClusterNodeListener primaryClusterNodeListener)

getDefaultClusterStoreProfile

public ClusterStoreProfile getDefaultClusterStoreProfile()

terminate

public void terminate()

Description copied from interface: ClusterManager

Terminates the cluster ungracefully forcing immediate shutdown.

Specified by:

terminate in interface ClusterManager

shutdown

public void shutdown()

Description copied from interface: ClusterManager

Terminates the cluster gracefully waiting for operations to be completed.

Specified by:

shutdown in interface ClusterManager

size

public int size()

Specified by:

size in interface ClusterManager

Returns:

the current number of active nodes in the cluster.

getSocketAddress

public InetSocketAddress getSocketAddress()

Specified by:

getSocketAddress in interface ClusterManager

Returns:

the local node address