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 6c7757bac..682325c8f 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 @@ -357,7 +357,7 @@ public class RedissonStreamCommands implements RedisStreamCommands { } return connection.write(key, StringCodec.INSTANCE, new RedisCommand<>("XPENDING", - new ListMultiDecoder2( + new ListMultiDecoder2( new PendingMessagesReplayDecoder(groupName, options.getRange()), new PendingMessageReplayDecoder(groupName))), params.toArray());