import akka.persistence.SaveSnapshotFailure;
import akka.persistence.SaveSnapshotSuccess;
import akka.persistence.SnapshotMetadata;
+import com.google.common.util.concurrent.MoreExecutors;
import java.io.OutputStream;
import java.util.Collections;
import java.util.Optional;
context = new RaftActorContextImpl(mockRaftActorRef, null, "test",
new ElectionTermImpl(mockPersistence, "test", LOG), -1, -1, Collections.<String,String>emptyMap(),
- configParams, mockPersistence, applyState -> { }, LOG) {
+ configParams, mockPersistence, applyState -> { }, LOG, MoreExecutors.directExecutor()) {
@Override
public SnapshotManager getSnapshotManager() {
return mockSnapshotManager;