From d13f9da212f05fc3100f7bb083e8f53edf2cab39 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Wed, 16 Jun 2021 13:43:07 +0200 Subject: [PATCH] Ensure all pipelined commands use a dedicated connection to avoid lingering commands when using pipelining with flushing customization. Original Pull Request: #2088 --- .../data/redis/connection/lettuce/LettuceConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java index 2ca7c62bc..238a8fab7 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java @@ -936,7 +936,7 @@ public class LettuceConnection extends AbstractRedisConnection { RedisClusterAsyncCommands getAsyncConnection() { - if (isQueueing()) { + if (isQueueing() || isPipelined()) { return getAsyncDedicatedConnection(); }