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());
                             }