From 0c8e578ac2c765237df16ca774903aa7f9d6f1a8 Mon Sep 17 00:00:00 2001 From: bwolf200 Date: Fri, 3 Oct 2014 18:19:27 -0700 Subject: [PATCH] tentative fix for sorted set redis cache not working properly for more than one redis shard --- src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java b/src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java index 5a64b938..d266dd0f 100644 --- a/src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java +++ b/src/com/comcast/cqs/persistence/RedisSortedSetPersistence.java @@ -1024,7 +1024,7 @@ public List receiveMessage(CQSQueue queue, Map 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 memIds;