package org.opendaylight.controller.cluster.raft.base.messages;
import akka.actor.ActorRef;
-import java.io.Serializable;
import org.opendaylight.controller.cluster.raft.ReplicatedLogEntry;
import org.opendaylight.yangtools.concepts.Identifier;
-public class Replicate implements Serializable {
- private static final long serialVersionUID = 1L;
+public class Replicate {
private final ActorRef clientActor;
private final Identifier identifier;
private final ReplicatedLogEntry replicatedLogEntry;
+ private final boolean sendImmediate;
- public Replicate(ActorRef clientActor, Identifier identifier, ReplicatedLogEntry replicatedLogEntry) {
-
+ public Replicate(ActorRef clientActor, Identifier identifier, ReplicatedLogEntry replicatedLogEntry,
+ boolean sendImmediate) {
this.clientActor = clientActor;
this.identifier = identifier;
this.replicatedLogEntry = replicatedLogEntry;
+ this.sendImmediate = sendImmediate;
}
public ActorRef getClientActor() {
public ReplicatedLogEntry getReplicatedLogEntry() {
return replicatedLogEntry;
}
+
+ public boolean isSendImmediate() {
+ return sendImmediate;
+ }
}