Ensure all pipelined commands use a dedicated connection to avoid lingering commands when using pipelining with flushing customization.

Original Pull Request: #2088
2021-06-16 13:43:07 +02:00
parent 8c743d40ef
commit d13f9da212
1 changed files with 1 additions and 1 deletions
--- 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<byte[], byte[]> getAsyncConnection() {

-		if (isQueueing()) {
+		if (isQueueing() || isPipelined()) {
 			return getAsyncDedicatedConnection();
 		}