Skip to content

Commit ac226de

Browse files
mp911dechristophstrobl
authored andcommitted
Fix: Ensure all pipelined commands use a dedicated connection to avoid lingering commands when using pipelining with flushing customization.
1 parent 1212a78 commit ac226de

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
@@ -936,7 +936,7 @@ void transaction(FutureResult<?> result) {
936936

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

939-
if (isQueueing()) {
939+
if (isQueueing() || isPipelined()) {
940940
return getAsyncDedicatedConnection();
941941
}
942942

0 commit comments

Comments
 (0)