Class ClusterJoinSocketInterceptor

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

public final class ClusterJoinSocketInterceptor extends Object implements com.hazelcast.nio.MemberSocketInterceptor, com.hazelcast.core.HazelcastInstanceAware
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 node's SerializationService

Since:
7.17.1
  • Constructor Details

    • ClusterJoinSocketInterceptor

      public ClusterJoinSocketInterceptor()
  • Method Details

    • init

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

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

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

      public void setHazelcastInstance(com.hazelcast.core.HazelcastInstance hazelcast)
      Specified by:
      setHazelcastInstance in interface com.hazelcast.core.HazelcastInstanceAware