JedisMock cannot be cast to DynoJedisClient

Tests fail without this fix.
Netflix · Jan 17, 2020 · ee40066 · ee40066
1 parent 12d242a
commit ee40066
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisQueues.java b/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisQueues.java
@@ -106,7 +106,12 @@ public RedisQueues(Clock clock, JedisCommands quorumConn, JedisCommands nonQuoru
         this.unackHandlerIntervalInMS = unackHandlerIntervalInMS;
         this.queues = new ConcurrentHashMap<>();
         this.shardingStrategy = shardingStrategy;
-        this.singleRingTopology = ((DynoJedisClient) quorumConn).getConnPool().getPools().size() == 3;
+
+        if (quorumConn instanceof DynoJedisClient) {
+            this.singleRingTopology = ((DynoJedisClient) quorumConn).getConnPool().getPools().size() == 3;
+        } else {
+            this.singleRingTopology = false;
+        }
     }
 
     /**