From cdd2835674e154979c893816f38229b5cdc73c59 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Art=C5=ABras=20=C5=A0lajus?= Date: Fri, 7 Feb 2025 15:42:04 +0200 Subject: [PATCH] Include command type in the timeout message It is very frustrating to get a stacktrace which does not indicate which command has failed when using async/reactive clients. --- .../java/io/lettuce/core/protocol/CommandExpiryWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/lettuce/core/protocol/CommandExpiryWriter.java b/src/main/java/io/lettuce/core/protocol/CommandExpiryWriter.java index dcd71e6d42..160deed187 100644 --- a/src/main/java/io/lettuce/core/protocol/CommandExpiryWriter.java +++ b/src/main/java/io/lettuce/core/protocol/CommandExpiryWriter.java @@ -179,8 +179,8 @@ private void potentiallyExpire(RedisCommand command, ScheduledExecutorS Timeout commandTimeout = timer.newTimeout(t -> { if (!command.isDone()) { - executors.submit(() -> command.completeExceptionally( - ExceptionFactory.createTimeoutException(Duration.ofNanos(timeUnit.toNanos(timeout))))); + executors.submit(() -> command.completeExceptionally(ExceptionFactory + .createTimeoutException(command.getType().toString(), Duration.ofNanos(timeUnit.toNanos(timeout))))); } }, timeout, timeUnit);