Class ClusterJoinSocketInterceptor

java.lang.Object
com.atlassian.confluence.impl.cluster.nutcluster.interceptor.ClusterJoinSocketInterceptor
All Implemented Interfaces:
com.atlassian.nutcluster.core.NutclusterInstanceAware, com.atlassian.nutcluster.nio.MemberSocketInterceptor, com.atlassian.nutcluster.nio.SocketInterceptor

public final class ClusterJoinSocketInterceptor extends Object implements com.atlassian.nutcluster.nio.MemberSocketInterceptor, com.atlassian.nutcluster.core.NutclusterInstanceAware
A MemberSocketInterceptor which delegates to ClusterJoinManager to verify if a member can join.

Unfortunately this cannot be a singleton as it requires access to the

invalid reference
node's
invalid reference
SerializationService
Since:
7.17.1
  • Constructor Details

    • ClusterJoinSocketInterceptor

      public ClusterJoinSocketInterceptor()
  • Method Details

    • init

      public void init(Properties properties)
      Specified by:
      init in interface com.atlassian.nutcluster.nio.SocketInterceptor
    • onAccept

      public void onAccept(Socket socket) throws IOException
      Specified by:
      onAccept in interface com.atlassian.nutcluster.nio.MemberSocketInterceptor
      Throws:
      IOException
    • onConnect

      public void onConnect(Socket socket) throws IOException
      Specified by:
      onConnect in interface com.atlassian.nutcluster.nio.SocketInterceptor
      Throws:
      IOException
    • setNutclusterInstance

      public void setNutclusterInstance(com.atlassian.nutcluster.core.NutclusterInstance nutcluster)
      Specified by:
      setNutclusterInstance in interface com.atlassian.nutcluster.core.NutclusterInstanceAware