Skip to content

Commit d9c446e

Browse files
mp911dechristophstrobl
authored andcommitted
Ensure all pipelined commands use a dedicated connection to avoid lingering commands when using pipelining with flushing customization.
Original Pull Request: #2088
1 parent 4cf24a1 commit d9c446e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -935,7 +935,7 @@ void transaction(FutureResult<?> result) {
935935

936936
RedisClusterAsyncCommands<byte[], byte[]> getAsyncConnection() {
937937

938-
if (isQueueing()) {
938+
if (isQueueing() || isPipelined()) {
939939
return getAsyncDedicatedConnection();
940940
}
941941

0 commit comments

Comments
 (0)