diff --git a/src/main/java/io/lettuce/core/cluster/ClusterCommand.java b/src/main/java/io/lettuce/core/cluster/ClusterCommand.java index 563c2e701d..1b884b8f0e 100644 --- a/src/main/java/io/lettuce/core/cluster/ClusterCommand.java +++ b/src/main/java/io/lettuce/core/cluster/ClusterCommand.java @@ -81,9 +81,8 @@ public void encode(ByteBuf buf) { @Override public boolean completeExceptionally(Throwable ex) { - boolean result = command.completeExceptionally(ex); completed = true; - return result; + return super.completeExceptionally(ex); } @Override