diff --git a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java index d79bf7cf7..ee9b2be3a 100644 --- a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java +++ b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java @@ -109,7 +109,7 @@ public class RedissonStreamCommands implements RedisStreamCommands { return connection.write(key, StringCodec.INSTANCE, XGROUP_STRING, "CREATE", key, groupName, readOffset.getOffset(), "MKSTREAM"); } - private static final RedisStrictCommand XGROUP_BOOLEAN = new RedisStrictCommand("XADD", obj -> ((Long)obj) > 0); + private static final RedisStrictCommand XGROUP_BOOLEAN = new RedisStrictCommand("XGROUP", obj -> ((Long)obj) > 0); @Override public Boolean xGroupDelConsumer(byte[] key, Consumer consumer) { diff --git a/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java b/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java index ee1d79e06..2e8ece2f7 100644 --- a/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java +++ b/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java @@ -395,7 +395,7 @@ public class RedissonStreamCommands implements RedisStreamCommands { return xGroupCreate(key, groupName, readOffset, false); } - private static final RedisStrictCommand XGROUP_BOOLEAN = new RedisStrictCommand("XADD", obj -> ((Long)obj) > 0); + private static final RedisStrictCommand XGROUP_BOOLEAN = new RedisStrictCommand("XGROUP", obj -> ((Long)obj) > 0); @Override public Boolean xGroupDelConsumer(byte[] key, Consumer consumer) { diff --git a/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java b/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java index 7fb5e81aa..72924f329 100644 --- a/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java +++ b/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonStreamCommands.java @@ -394,7 +394,7 @@ public class RedissonStreamCommands implements RedisStreamCommands { return xGroupCreate(key, groupName, readOffset, false); } - private static final RedisStrictCommand XGROUP_BOOLEAN = new RedisStrictCommand("XADD", obj -> ((Long)obj) > 0); + private static final RedisStrictCommand XGROUP_BOOLEAN = new RedisStrictCommand("XGROUP", obj -> ((Long)obj) > 0); @Override public Boolean xGroupDelConsumer(byte[] key, Consumer consumer) {