com.mulesoft.mule.runtime.module.cluster.api

Interface ClusterManager

All Superinterfaces:

PrimaryClusterNodeListener

All Known Implementing Classes:

HazelcastClusterManager

@NoImplement
public interface ClusterManager
extends PrimaryClusterNodeListener

Provides management capabilities for the cluster instance

Since:

4.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	CLUSTER_MANAGER_ID

Method Summary

Modifier and Type	Method and Description
String	getClusterId()
String	getClusterNodeId()
ClusterLocker	getPrimaryNodePollingThread()
InetSocketAddress	getSocketAddress()
default boolean	isClientModeEnabled()
boolean	isPrimaryPollingInstance()
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.

Methods inherited from interface com.mulesoft.mule.runtime.module.cluster.api.notification.PrimaryClusterNodeListener

onNotification

Field Detail

CLUSTER_MANAGER_ID

static final String CLUSTER_MANAGER_ID

See Also:

Constant Field Values

Method Detail

isPrimaryPollingInstance

boolean isPrimaryPollingInstance()

Returns:

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

setAsPollingNode

void setAsPollingNode(boolean isPoller)

Configures the polling status of the current cluster node.

Parameters:

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

getPrimaryNodePollingThread

ClusterLocker getPrimaryNodePollingThread()

Returns:

the ClusterLocker for the cluster node.

terminate

void terminate()

Terminates the cluster ungracefully forcing immediate shutdown.

shutdown

void shutdown()

Terminates the cluster gracefully waiting for operations to be completed.

size

int size()

Returns:

the current number of active nodes in the cluster.

getClusterNodeId

String getClusterNodeId()

Returns:

the cluster's node identifier

getClusterId

String getClusterId()

Returns:

the cluster identifier

getSocketAddress

InetSocketAddress getSocketAddress()

Returns:

the local node address

isClientModeEnabled

default boolean isClientModeEnabled()

Returns:

whether is client mode enabled