fixed wrong cause has been logged

swisspost · Dec 12, 2024 · 9ae03c8 · 9ae03c8
1 parent fe3b03a
commit 9ae03c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java
@@ -1208,7 +1208,7 @@ private Future<Void> notifyConsumer(final String queueName) {
                         log.warn("RedisQues consumer {} of queue {} does not exist.", consumer, queueName);
                         redisAPI.del(Collections.singletonList(key), result -> {
                             if (result.failed()) {
-                                log.warn("Failed to removed consumer '{}'", key, exceptionFactory.newException(event.cause()));
+                                log.warn("Failed to removed consumer '{}'", key, exceptionFactory.newException(result.cause()));
                             } else {
                                 log.debug("{} consumer key removed",  result.result().toLong());
                             }