com.hazelcast.internal.cluster.impl

Class SplitBrainMulticastListener

java.lang.Object

com.hazelcast.internal.cluster.impl.SplitBrainMulticastListener

All Implemented Interfaces:

MulticastListener

public class SplitBrainMulticastListener
extends Object
implements MulticastListener

Listens for SplitBrainJoinMessages and adds them for processing by split brain handler. Each messages is added to the head of a BlockingDeque, so that polling the BlockingDeque will return the message received last (thus operating as a stack).

Constructor Summary

Constructors

Constructor and Description
SplitBrainMulticastListener(Node node, BlockingDeque<SplitBrainJoinMessage> deque)

Method Summary

Modifier and Type	Method and Description
void	onMessage(Object msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

SplitBrainMulticastListener

public SplitBrainMulticastListener(Node node,
                                   BlockingDeque<SplitBrainJoinMessage> deque)

Method Detail

onMessage

public void onMessage(Object msg)

Specified by:

onMessage in interface MulticastListener