diff --git a/redisson/src/test/java/org/redisson/RedissonStreamTest.java b/redisson/src/test/java/org/redisson/RedissonStreamTest.java index 5032ba940..b66ae09de 100644 --- a/redisson/src/test/java/org/redisson/RedissonStreamTest.java +++ b/redisson/src/test/java/org/redisson/RedissonStreamTest.java @@ -472,9 +472,13 @@ public class RedissonStreamTest extends BaseTest { Map entries = new HashMap<>(); entries.put("6", "61"); entries.put("4", "41"); - stream.addAll(new StreamMessageId(12, 42), entries, 10, false); + StreamMessageId id = new StreamMessageId(12, 42); + stream.addAll(id, entries, 10, false); assertThat(stream.size()).isEqualTo(1); + Map> res = stream.read(new StreamMessageId(10, 42)); + assertThat(res.get(id).size()).isEqualTo(2); + entries.clear(); entries.put("1", "11"); entries.put("3", "31");