import org.opendaylight.controller.cluster.raft.client.messages.GetSnapshotReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import scala.concurrent.duration.Duration;
+import scala.concurrent.duration.FiniteDuration;
/**
* Temporary actor used by the ShardManager to compile GetSnapshot replies from the Shard actors and return
public static Props props(final Collection<String> shardNames, final String datastoreType,
final ShardManagerSnapshot shardManagerSnapshot, final ActorRef replyToActor, final String id,
- final Duration receiveTimeout) {
+ final FiniteDuration receiveTimeout) {
return Props.create(ShardManagerGetSnapshotReplyActor.class, new Params(shardNames, datastoreType,
shardManagerSnapshot, replyToActor, id, receiveTimeout));
}
final ShardManagerSnapshot shardManagerSnapshot;
final ActorRef replyToActor;
final String id;
- final Duration receiveTimeout;
+ final FiniteDuration receiveTimeout;
Params(final Collection<String> shardNames, final String datastoreType,
final ShardManagerSnapshot shardManagerSnapshot, final ActorRef replyToActor, final String id,
- final Duration receiveTimeout) {
+ final FiniteDuration receiveTimeout) {
this.shardNames = shardNames;
this.datastoreType = datastoreType;
this.shardManagerSnapshot = shardManagerSnapshot;