public class StreamEntryID extends java.lang.Object implements java.lang.Comparable<StreamEntryID>, java.io.Serializable
限定符和类型 | 字段和说明 |
---|---|
static StreamEntryID |
LAST_ENTRY
Should be used only with XGROUP CREATE
XGROUP CREATE mystream consumer-group-name $
|
static StreamEntryID |
NEW_ENTRY
Should be used only with XADD
XADD mystream * field1 value1
|
static StreamEntryID |
UNRECEIVED_ENTRY
Should be used only with XREADGROUP
XREADGROUP $GroupName $ConsumerName BLOCK 2000 COUNT 10 STREAMS mystream >
|
构造器和说明 |
---|
StreamEntryID() |
StreamEntryID(long time,
long sequence) |
StreamEntryID(java.lang.String id) |
限定符和类型 | 方法和说明 |
---|---|
int |
compareTo(StreamEntryID other) |
boolean |
equals(java.lang.Object obj) |
long |
getSequence() |
long |
getTime() |
int |
hashCode() |
java.lang.String |
toString() |
public static final StreamEntryID NEW_ENTRY
XADD mystream * field1 value1
public static final StreamEntryID LAST_ENTRY
XGROUP CREATE mystream consumer-group-name $
public static final StreamEntryID UNRECEIVED_ENTRY
XREADGROUP $GroupName $ConsumerName BLOCK 2000 COUNT 10 STREAMS mystream >
public StreamEntryID()
public StreamEntryID(java.lang.String id)
public StreamEntryID(long time, long sequence)
public java.lang.String toString()
toString
在类中 java.lang.Object
public boolean equals(java.lang.Object obj)
equals
在类中 java.lang.Object
public int hashCode()
hashCode
在类中 java.lang.Object
public int compareTo(StreamEntryID other)
compareTo
在接口中 java.lang.Comparable<StreamEntryID>
public long getTime()
public long getSequence()