From 9ae03c8537a118dea2c4e9721749a913655511ab Mon Sep 17 00:00:00 2001
From: Xin Zheng <xin.zheng@post.ch>
Date: Thu, 12 Dec 2024 13:48:54 +0700
Subject: [PATCH] fixed wrong cause has been logged

---
 src/main/java/org/swisspush/redisques/RedisQues.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/swisspush/redisques/RedisQues.java b/src/main/java/org/swisspush/redisques/RedisQues.java
index c46be73..26d75f1 100644
--- 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());
                             }