From 00e779f2fe37045ca2a82669bcf29c4b81f74525 Mon Sep 17 00:00:00 2001 From: Jonathan Cobb Date: Mon, 3 Feb 2020 21:03:39 -0500 Subject: [PATCH] add del_withPrefix --- .../org/cobbzilla/wizard/cache/redis/RedisService.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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 4470f50..047b628 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 @@ -161,7 +161,8 @@ public class RedisService { public Set hkeys(String key) { return __hkeys(key, 0, MAX_RETRIES); } public Long hlen(String key) { return __hlen(key, 0, MAX_RETRIES); } - public void del(String key) { __del(key, 0, MAX_RETRIES); } + public Long del(String key) { return __del(key, 0, MAX_RETRIES); } + public Long del_withPrefix(String prefixedKey) { return __del(prefixedKey, 0, MAX_RETRIES, false); } public void set_plaintext(String key, String value, String nxxx, String expx, long time) { __set(key, value, nxxx, expx, time, 0, MAX_RETRIES); @@ -493,6 +494,10 @@ public class RedisService { } private Long __del(String key, int attempt, int maxRetries) { + return __del(key, attempt, maxRetries, true); + } + + private Long __del(String key, int attempt, int maxRetries, boolean applyPrefix) { try { synchronized (redis) { return getRedis().del(prefix(key)); @@ -500,7 +505,7 @@ public class RedisService { } catch (RuntimeException e) { if (attempt > maxRetries) throw e; resetForRetry(attempt, "retrying RedisService.__del"); - return __del(key, attempt+1, maxRetries); + return __del(key, attempt+1, maxRetries, applyPrefix); } }