Package redis.clients.jedis
Class StreamEntryID
java.lang.Object
redis.clients.jedis.StreamEntryID
- All Implemented Interfaces:
Serializable,Comparable<StreamEntryID>
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StreamEntryIDShould be used only with XGROUP CREATEXGROUP CREATE mystream consumer-group-name $static final StreamEntryIDCan be used in XRANGE, XREVRANGE and XPENDING commands.static final StreamEntryIDCan be used in XRANGE, XREVRANGE and XPENDING commands.static final StreamEntryIDShould be used only with XADDXADD mystream * field1 value1private longprivate static final longprivate longstatic final StreamEntryIDShould be used only with XREADGROUP -
Constructor Summary
ConstructorsConstructorDescriptionStreamEntryID(byte[] id) StreamEntryID(long time) StreamEntryID(long time, long sequence) StreamEntryID(String id) -
Method Summary
Modifier and TypeMethodDescriptionintcompareTo(StreamEntryID other) booleanlonglonggetTime()inthashCode()private voidtoString()private void
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
time
private long time -
sequence
private long sequence -
NEW_ENTRY
Should be used only with XADDXADD mystream * field1 value1 -
LAST_ENTRY
Should be used only with XGROUP CREATEXGROUP CREATE mystream consumer-group-name $ -
UNRECEIVED_ENTRY
Should be used only with XREADGROUPXREADGROUP $GroupName $ConsumerName BLOCK 2000 COUNT 10 STREAMS mystream > -
MINIMUM_ID
Can be used in XRANGE, XREVRANGE and XPENDING commands. -
MAXIMUM_ID
Can be used in XRANGE, XREVRANGE and XPENDING commands.
-
-
Constructor Details
-
StreamEntryID
public StreamEntryID() -
StreamEntryID
public StreamEntryID(byte[] id) -
StreamEntryID
-
StreamEntryID
public StreamEntryID(long time) -
StreamEntryID
public StreamEntryID(long time, long sequence)
-
-
Method Details
-
toString
-
equals
-
hashCode
public int hashCode() -
compareTo
- Specified by:
compareToin interfaceComparable<StreamEntryID>
-
getTime
public long getTime() -
getSequence
public long getSequence() -
writeObject
- Throws:
IOException
-
readObject
- Throws:
IOExceptionClassNotFoundException
-