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 2854db5b1..91f1add1b 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 @@ -1051,6 +1051,7 @@ public class LettuceConnection implements RedisConnection { try { if (isPipelined()) { pipeline(new LettuceStatusResult(getAsyncConnection().setbit(key, offset, LettuceConverters.toInt(value)))); + return; } getConnection().setbit(key, offset, LettuceConverters.toInt(value)); } catch (Exception ex) { @@ -1063,6 +1064,7 @@ public class LettuceConnection implements RedisConnection { try { if (isPipelined()) { pipeline(new LettuceStatusResult(getAsyncConnection().setrange(key, start, value))); + return; } getConnection().setrange(key, start, value); } catch (Exception ex) {