diff --git a/wizard-server/src/main/java/org/cobbzilla/wizard/cache/redis/RedisService.java b/wizard-server/src/main/java/org/cobbzilla/wizard/cache/redis/RedisService.java index 402986f..4470f50 100644 --- a/wizard-server/src/main/java/org/cobbzilla/wizard/cache/redis/RedisService.java +++ b/wizard-server/src/main/java/org/cobbzilla/wizard/cache/redis/RedisService.java @@ -383,15 +383,15 @@ public class RedisService { } } - private String __lpop(String data, int attempt, int maxRetries) { + private String __lpop(String key, int attempt, int maxRetries) { try { synchronized (redis) { - return getRedis().lpop(data); + return getRedis().lpop(prefix(key)); } } catch (RuntimeException e) { if (attempt > maxRetries) throw e; resetForRetry(attempt, "retrying RedisService.__lpop"); - return __lpop(data, attempt+1, maxRetries); + return __lpop(key, attempt+1, maxRetries); } }