X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorSnapshotMessageSupport.java;h=3b4c08c405bf02dace5565602d663166e4643e3f;hp=4d68d8ea160d20b9ba8ec30072bacb21dc2c44e0;hb=refs%2Fchanges%2F49%2F78449%2F2;hpb=a4fcc7debbd036c6e1df8c88df1c0268c62e76e4 diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java index 4d68d8ea16..3b4c08c405 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java @@ -22,7 +22,7 @@ import org.opendaylight.controller.cluster.raft.client.messages.GetSnapshotReply import org.opendaylight.controller.cluster.raft.persisted.EmptyState; import org.opendaylight.controller.cluster.raft.persisted.Snapshot; import org.slf4j.Logger; -import scala.concurrent.duration.Duration; +import scala.concurrent.duration.FiniteDuration; /** * Handles snapshot related messages for a RaftActor. @@ -41,7 +41,7 @@ class RaftActorSnapshotMessageSupport { private final RaftActorSnapshotCohort cohort; private final Logger log; - private Duration snapshotReplyActorTimeout = Duration.create(30, TimeUnit.SECONDS); + private FiniteDuration snapshotReplyActorTimeout = FiniteDuration.create(30, TimeUnit.SECONDS); RaftActorSnapshotMessageSupport(final RaftActorContext context, final RaftActorSnapshotCohort cohort) { this.context = context; @@ -129,7 +129,7 @@ class RaftActorSnapshotMessageSupport { } @VisibleForTesting - void setSnapshotReplyActorTimeout(Duration snapshotReplyActorTimeout) { + void setSnapshotReplyActorTimeout(FiniteDuration snapshotReplyActorTimeout) { this.snapshotReplyActorTimeout = snapshotReplyActorTimeout; } }