com.atlassian.confluence.impl.cluster.hazelcast.interceptor.authenticator

Class DefaultClusterJoinManager

java.lang.Object

com.atlassian.confluence.impl.cluster.hazelcast.interceptor.authenticator.DefaultClusterJoinManager

All Implemented Interfaces:

ClusterJoinManager

public class DefaultClusterJoinManager
extends Object
implements ClusterJoinManager

A ClusterJoinManager which first authenticates new connections

Warning: Do not use AOP interceptors around this class!. Doing so can produce unexpected delays in join check processing, which can result in delays when nodes that are starting first attempt to join an existing cluster. That can result in nodes promoting themselves to full members and then clustering "later", defeating our configuration for nodes to join existing clusters as "lite" members (which can't hold partitioned data) until the application is fully started.

Since:

7.17.3

Constructor Summary

Constructors

Constructor and Description
DefaultClusterJoinManager(ClusterAuthenticator clusterAuthenticator, boolean enableNodeAuthentication)

Method Summary

Modifier and Type	Method and Description
void	accept(ClusterJoinRequest request) The implementation of this method matches that of connect(ClusterJoinRequest) but from the other side.
void	connect(ClusterJoinRequest request) Attempt to join an existing cluster

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultClusterJoinManager

public DefaultClusterJoinManager(ClusterAuthenticator clusterAuthenticator,
                                 boolean enableNodeAuthentication)

Method Detail

accept

public void accept(@Nonnull
                   ClusterJoinRequest request)
            throws IOException

The implementation of this method matches that of connect(ClusterJoinRequest) but from the other side.

Specified by:

accept in interface ClusterJoinManager

Parameters:

request - the join request

Throws:

IOException - if the join negotiation failed, or a communication breakdown occurs

See Also:

connect(ClusterJoinRequest)

connect

public void connect(@Nonnull
                    ClusterJoinRequest request)
             throws IOException

Description copied from interface: ClusterJoinManager

Attempt to join an existing cluster

Specified by:

connect in interface ClusterJoinManager

Parameters:

request - the join request

Throws:

IOException - if the join negotiation failed, or a communication breakdown occurs