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

mp911de · christophstrobl · commit 9258b582c93c · 2021-06-29T09:17:36.000+02:00
Original Pull Request: #2088
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
@@ -943,7 +943,7 @@ void transaction(FutureResult<?> result) {
 	}
 
 	RedisClusterAsyncCommands<byte[], byte[]> getAsyncConnection() {
-		if (isQueueing()) {
+		if (isQueueing() || isPipelined()) {
 			return getAsyncDedicatedConnection();
 		}
 		if (asyncSharedConn != null) {

Original file line number	Diff line number	Diff line change
`@@ -943,7 +943,7 @@ void transaction(FutureResult<?> result) {`
`943`	`943`	`}`
`944`	`944`
`945`	`945`	`RedisClusterAsyncCommands<byte[], byte[]> getAsyncConnection() {`
`946`		`- if (isQueueing()) {`
	`946`	`+ if (isQueueing() \|\| isPipelined()) {`
`947`	`947`	`return getAsyncDedicatedConnection();`
`948`	`948`	`}`
`949`	`949`	`if (asyncSharedConn != null) {`