import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.japi.Procedure;
-
import com.google.protobuf.GeneratedMessage;
-
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
-
import org.opendaylight.controller.cluster.NonPersistentDataProvider;
import org.opendaylight.controller.cluster.raft.policy.RaftPolicy;
import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload;
import org.opendaylight.controller.protobuff.messages.cluster.raft.AppendEntriesMessages;
-import org.opendaylight.controller.protobuff.messages.cluster.raft.test.MockPayloadMessages;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public MockRaftActorContext(){
super(null, null, "test", newElectionTerm(), -1, -1, new HashMap<String, String>(),
new DefaultConfigParamsImpl(), new NonPersistentDataProvider(), LOG);
+ setReplicatedLog(new MockReplicatedLogBuilder().build());
}
public MockRaftActorContext(String id, ActorSystem system, ActorRef actor){
}
@Override public Map<GeneratedMessage.GeneratedExtension<?, ?>, String> encode() {
- Map<GeneratedMessage.GeneratedExtension<?, ?>, String> map = new HashMap<>();
- map.put(MockPayloadMessages.value, value);
- return map;
+ return null;
}
@Override public Payload decode(
AppendEntriesMessages.AppendEntries.ReplicatedLogEntry.Payload payloadProtoBuff) {
- String value = payloadProtoBuff.getExtension(MockPayloadMessages.value);
- this.value = value;
- return this;
+ return null;
}
@Override