io.lettuce.core.models.stream

Class ClaimedMessages<K,V>

java.lang.Object

io.lettuce.core.models.stream.ClaimedMessages<K,V>

public class ClaimedMessages<K,V>
extends Object

Value object representing the claimed messages reported through XAUTOCLAIM.

Since:

6.1

Author:

dengliming

Constructor Summary

Constructors

Constructor and Description
ClaimedMessages(String id, List<StreamMessage<K,V>> messages) Create a new ClaimedMessages.
ClaimedMessages(String id, List<StreamMessage<K,V>> messages, List<String> deletedIds) Create a new ClaimedMessages with deleted entry IDs.

Method Summary

Modifier and Type	Method and Description
List<String>	getDeletedIds() Returns the IDs of pending entries that were removed from the PEL because they no longer exist in the stream.
String	getId()
List<StreamMessage<K,V>>	getMessages()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClaimedMessages

public ClaimedMessages(String id,
                       List<StreamMessage<K,V>> messages)

Create a new ClaimedMessages.

Parameters:

id - the stream ID to use as the cursor for the next XAUTOCLAIM call.

messages - the claimed messages.

ClaimedMessages

public ClaimedMessages(String id,
                       List<StreamMessage<K,V>> messages,
                       List<String> deletedIds)

Create a new ClaimedMessages with deleted entry IDs.

Parameters:

id - the stream ID to use as the cursor for the next XAUTOCLAIM call.

messages - the claimed messages.

deletedIds - the IDs the server removed from the PEL, or null for an empty list.

Since:

7.8

Method Detail

getId

public String getId()

getMessages

public List<StreamMessage<K,V>> getMessages()

getDeletedIds

public List<String> getDeletedIds()

Returns the IDs of pending entries that were removed from the PEL because they no longer exist in the stream.

XAUTOCLAIM returns these IDs in a third reply element since Redis 7.0. Returns an empty list when the server responds with only two elements (Redis before 7.0).

Returns:

the IDs of PEL entries that were deleted from the stream, never null.

Since:

7.8