Resolved forward reference in RedisCluster

etaty · Jul 7, 2019 · aac07d2 · aac07d2
1 parent c700141
commit aac07d2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/main/scala/redis/RedisCluster.scala b/src/main/scala/redis/RedisCluster.scala
@@ -23,6 +23,9 @@ case class RedisCluster(redisServers: Seq[RedisServer],
 
   val log = Logging.getLogger(_system, this)
 
+  val clusterSlotsRef:Ref[Option[Map[ClusterSlot, RedisConnection]]] = Ref(Option.empty[Map[ClusterSlot, RedisConnection]])
+  val lockClusterSlots = Ref(true)
+
   override val redisServerConnections = {
     redisServers.map { server =>
       makeRedisConnection(server, defaultActive = true)
@@ -51,10 +54,6 @@ case class RedisCluster(redisServers: Seq[RedisServer],
     }
   }
 
-  val clusterSlotsRef:Ref[Option[Map[ClusterSlot, RedisConnection]]] = Ref(Option.empty[Map[ClusterSlot, RedisConnection]])
-  val lockClusterSlots = Ref(true)
-  Await.result(asyncRefreshClusterSlots(force=true), Duration(10,TimeUnit.SECONDS))
-
   def getClusterSlots(): Future[Map[ClusterSlot, RedisConnection]] = {
 
     def resolveClusterSlots(retry:Int): Future[Map[ClusterSlot, RedisConnection]] = {
@@ -183,6 +182,7 @@ case class RedisCluster(redisServers: Seq[RedisServer],
     }.values.toSeq
   }
 
+  Await.result(asyncRefreshClusterSlots(force=true), Duration(10,TimeUnit.SECONDS))
 }