com.hazelcast.replicatedmap.impl.record

Class ReplicationPublisher<K,V>

java.lang.Object

com.hazelcast.replicatedmap.impl.record.ReplicationPublisher<K,V>

Type Parameters:

K -

V -

All Implemented Interfaces:

ReplicationChannel

public class ReplicationPublisher<K,V>
extends Object
implements ReplicationChannel

This class implements the actual replication logic for replicated map

Method Summary

Methods

Modifier and Type	Method and Description
void	distributeClear(boolean emptyReplicationQueue)
void	emptyReplicationQueue()
void	publishReplicatedMessage(ReplicationMessage message)
void	queuePreProvision(Address callerAddress, int chunkSize)
void	queueUpdateMessage(ReplicationMessage update)
void	queueUpdateMessages(MultiReplicationMessage updates)
void	replicate(MultiReplicationMessage message)
void	replicate(ReplicationMessage message)
void	retryWithDifferentReplicationNode(Member member)
void	setPreReplicationHook(PreReplicationHook preReplicationHook)

Methods inherited from class java.lang.Object

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

Method Detail

replicate

public void replicate(MultiReplicationMessage message)

Specified by:

replicate in interface ReplicationChannel

replicate

public void replicate(ReplicationMessage message)

Specified by:

replicate in interface ReplicationChannel

setPreReplicationHook

public void setPreReplicationHook(PreReplicationHook preReplicationHook)

publishReplicatedMessage

public void publishReplicatedMessage(ReplicationMessage message)

queueUpdateMessage

public void queueUpdateMessage(ReplicationMessage update)

queueUpdateMessages

public void queueUpdateMessages(MultiReplicationMessage updates)

queuePreProvision

public void queuePreProvision(Address callerAddress,
                     int chunkSize)

retryWithDifferentReplicationNode

public void retryWithDifferentReplicationNode(Member member)

distributeClear

public void distributeClear(boolean emptyReplicationQueue)

emptyReplicationQueue

public void emptyReplicationQueue()