diff --git a/redisson/src/main/java/org/redisson/api/StreamMessageId.java b/redisson/src/main/java/org/redisson/api/StreamMessageId.java index 632314dee..cae87fbf3 100644 --- a/redisson/src/main/java/org/redisson/api/StreamMessageId.java +++ b/redisson/src/main/java/org/redisson/api/StreamMessageId.java @@ -58,6 +58,13 @@ public class StreamMessageId { */ public static final StreamMessageId NEWEST = new StreamMessageId(-1); + /** + * Defines id to receive Stream entries since the last message. + * <p> + * Used in {@link RStream#read}, {@link RStream#createGroup} methods + */ + public static final StreamMessageId LAST = new StreamMessageId(-1); + /** * Defines id to receive all Stream entries. * <p> @@ -135,6 +142,9 @@ public class StreamMessageId { if (this == NEVER_DELIVERED) { return ">"; } + if (this == LAST) { + return "+"; + } if (this == NEWEST) { return "$"; }