|
|
|
@ -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 "$";
|
|
|
|
|
}
|
|
|
|
|