tentative fix for sorted set redis cache not working properly for more

than one redis shard
zhishihei · Oct 4, 2014 · 0c8e578 · 0c8e578
1 parent a2b4fad
commit 0c8e578
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java b/src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java
@@ -1024,7 +1024,7 @@ public List<CQSMessage> receiveMessage(CQSQueue queue, Map<String, String> recei
             try {
 
             	jedis = getResource();
-            	Jedis j = jedis.getShard(queue.getRelativeUrl() + "-" + shard + "-" + CQSConstants.REDIS_STATE);
+            	Jedis j = jedis.getShard(queue.getRelativeUrl() + "-" + shard + "-" + "Q");
                 boolean done = false;
                 String key = queue.getRelativeUrl() + "-" + shard + "-Q";
                 Set <String> memIds;