Fixed - RedissonLocalCachedMap.clearLocalCache() method throws IllegalArgumentException #4187

3 years ago · d424d249a2
parent a8aeac3eb5
commit d424d249a2
1 changed files with 4 additions and 0 deletions
--- a/redisson/src/main/java/org/redisson/cache/LocalCacheListener.java
+++ b/redisson/src/main/java/org/redisson/cache/LocalCacheListener.java
@ -250,6 +250,10 @@ public abstract class LocalCacheListener {
        byte[] id = generateId();
        RFuture<Long> future = invalidationTopic.publishAsync(new LocalCachedMapClear(instanceId, id, true));
        CompletionStage<Void> f = future.thenCompose(res -> {
+            if (res.intValue() == 0) {
+                return CompletableFuture.completedFuture(null);
+            }
+
            RSemaphore semaphore = getClearSemaphore(id);
            return semaphore.tryAcquireAsync(res.intValue() - 1, 50, TimeUnit.SECONDS)
                    .thenCompose(r -> {