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

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 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 Summary

Constructors

Constructor	Description
ClusterJoinSocketInterceptor()

Method Summary

Modifier and Type	Method	Description
void	init(Properties properties)
void	onAccept(Socket socket)
void	onConnect(Socket socket)
void	setHazelcastInstance(com.hazelcast.core.HazelcastInstance hazelcast)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterJoinSocketInterceptor

public ClusterJoinSocketInterceptor()

Method Detail

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