diff --git a/redisson/src/main/java/org/redisson/RedissonStream.java b/redisson/src/main/java/org/redisson/RedissonStream.java index fad793c1e..23a4f586e 100644 --- a/redisson/src/main/java/org/redisson/RedissonStream.java +++ b/redisson/src/main/java/org/redisson/RedissonStream.java @@ -1406,7 +1406,7 @@ public class RedissonStream extends RedissonExpirable implements RStream params = new LinkedList<>(); params.add(getRawName()); - if (pps.getMaxLen() > 0) { + if (pps.getMaxLen() != null) { params.add("MAXLEN"); if (!trimStrict) { params.add("~"); diff --git a/redisson/src/main/java/org/redisson/api/stream/StreamTrimParams.java b/redisson/src/main/java/org/redisson/api/stream/StreamTrimParams.java index c4d6a49c8..07cd3ee47 100644 --- a/redisson/src/main/java/org/redisson/api/stream/StreamTrimParams.java +++ b/redisson/src/main/java/org/redisson/api/stream/StreamTrimParams.java @@ -26,7 +26,7 @@ public final class StreamTrimParams implements StreamTrimStrategyArgs { - int maxLen; + Integer maxLen; StreamMessageId minId; int limit; @@ -62,7 +62,7 @@ public final class StreamTrimParams implements StreamTrimStrategyArgs stream2 = redisson.getStream("myStream"); + StreamTrimArgs trimArgs = StreamTrimArgs.maxLen(0).noLimit(); + assertThat(stream2.trim(trimArgs)).isZero(); } @Test