Package com.atlassian.confluence.impl.cluster

Interface ClusterManagerInternal

All Superinterfaces:

ClusterExecutionService, ClusterManager

All Known Implementing Classes:

NonClusterManager, NutclusterClusterManager

public interface ClusterManagerInternal
extends ClusterManager

Since:

9.0

Field Summary

Fields inherited from interface com.atlassian.confluence.cluster.ClusterExecutionService

DEFAULT_EXECUTOR_SVC_NAME

Method Summary

Modifier and Type	Method	Description
void	configure(ClusterConfig config)	Set a new cluster configuration.
@Nullable ClusterInvariants	getClusterInvariants()	Get all attributes of the server that must be consistent between the nodes of a stable cluster.
boolean	isConfigured()
void	publishEvent(Serializable event)	Publish an event as a ClusterEventWrapper to other nodes
void	publishEventImmediately(Serializable event)	Publish immediately, an event as a ClusterEventWrapper to other nodes
void	reconfigure(ClusterConfig config)	Set a new cluster configuration and cycle the service
void	startCluster()	Start the clustering service
void	stopCluster()	Stop the clustering service

Methods inherited from interface com.atlassian.confluence.cluster.ClusterExecutionService

submitToAllNodes, submitToKeyOwner, submitToNode

Methods inherited from interface com.atlassian.confluence.cluster.ClusterManager

getAllNodesInformation, getClusterInformation, getClusterUptime, getNodeStatusMap, getThisNodeInformation, isClustered, release, tryAcquire

Method Details

configure

void configure(ClusterConfig config)

Set a new cluster configuration.

Parameters:

config -

isConfigured

boolean isConfigured()

Returns:

true if configure(ClusterConfig) has been called with a valid configuration, otherwise false.

reconfigure

void reconfigure(ClusterConfig config)
          throws ClusterException

Set a new cluster configuration and cycle the service

Parameters:

config -

Throws:

ClusterException

stopCluster

void stopCluster()

Stop the clustering service

startCluster

void startCluster()
           throws ClusterException

Start the clustering service

Throws:

ClusterException

getClusterInvariants

@Nullable ClusterInvariants getClusterInvariants()
                                          throws ClusterException

Get all attributes of the server that must be consistent between the nodes of a stable cluster. They are to be retrieved from another member in the cluster. If there are no other members currently active in the cluster, then return null.

Returns:

the cluster invariants of this server

Throws:

ClusterException - if the invariants can not be gathered for some reason

publishEvent

void publishEvent(Serializable event)

Publish an event as a ClusterEventWrapper to other nodes

This waits for any current transaction to be committed successfully before scheduling the event for publishing.

publishEventImmediately

void publishEventImmediately(Serializable event)

Publish immediately, an event as a ClusterEventWrapper to other nodes

This is done immediately regardless of the state of any current transactions.