Some raft message classes are Serializable but they don't need to
be as they're only sent locally.
Change-Id: Ibd052b9a4589dd2476b30c51e301b3dd609df750
Signed-off-by: Tom Pantelis <tompantelis@gmail.com>
package org.opendaylight.controller.cluster.raft.base.messages;
import akka.actor.ActorRef;
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;
import org.opendaylight.controller.cluster.raft.ReplicatedLogEntry;
import org.opendaylight.yangtools.concepts.Identifier;
-public class ApplyState implements Serializable {
- private static final long serialVersionUID = 1L;
+/**
+ * Local message sent by a RaftActor to itself to signal state has been applied to the state machine.
+ */
+public class ApplyState {
private final ActorRef clientActor;
private final Identifier identifier;
private final ReplicatedLogEntry replicatedLogEntry;
private final ActorRef clientActor;
private final Identifier identifier;
private final ReplicatedLogEntry replicatedLogEntry;
package org.opendaylight.controller.cluster.raft.base.messages;
package org.opendaylight.controller.cluster.raft.base.messages;
-import java.io.Serializable;
-
- * Message sent to indicate the current election term has timed out.
+ * Local message sent to indicate the current election term has timed out.
-public final class ElectionTimeout implements Serializable {
- private static final long serialVersionUID = 1L;
+public final class ElectionTimeout {
public static final ElectionTimeout INSTANCE = new ElectionTimeout();
private ElectionTimeout() {
public static final ElectionTimeout INSTANCE = new ElectionTimeout();
private ElectionTimeout() {
package org.opendaylight.controller.cluster.raft.base.messages;
package org.opendaylight.controller.cluster.raft.base.messages;
-import java.io.Serializable;
-
-public class InitiateCaptureSnapshot implements Serializable {
- private static final long serialVersionUID = 1L;
+public class InitiateCaptureSnapshot {
package org.opendaylight.controller.cluster.raft.base.messages;
import akka.actor.ActorRef;
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;
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 ActorRef clientActor;
private final Identifier identifier;
private final ReplicatedLogEntry replicatedLogEntry;
package org.opendaylight.controller.cluster.raft.base.messages;
package org.opendaylight.controller.cluster.raft.base.messages;
-import java.io.Serializable;
-
/**
* This messages is sent via a schedule to the Leader to prompt it to send a heart beat to its followers.
*/
/**
* This messages is sent via a schedule to the Leader to prompt it to send a heart beat to its followers.
*/
-public final class SendHeartBeat implements Serializable {
- private static final long serialVersionUID = 1L;
+public final class SendHeartBeat {
public static final SendHeartBeat INSTANCE = new SendHeartBeat();
private SendHeartBeat() {
public static final SendHeartBeat INSTANCE = new SendHeartBeat();
private SendHeartBeat() {