В каком порядке сообщения возвращаются командой xpending? ⇐ JAVA
-
Гость
В каком порядке сообщения возвращаются командой xpending?
У меня есть приложение, которое я создал с использованием Spring Boot, и оно считывает данные из потока Redis. Я вызываю операцию xpending через API-интерфейс Spring Boot "opsForStream()" - это выглядит так:
private PendingMessages getPending() { return this.redisTransactionTemplate.opsForStream().pending(streamKey, groupName, Range.unbounded(), 1000); } Затем я хочу взять эти 1000 (или меньше) ожидающих сообщений и затем вызвать xrange. Однако я не уверен, что эти ожидающие сообщения расположены в порядке от самого раннего к последнему. В идеале я хочу использовать ожидающие сообщения по порядку, но не хочу предполагать, что они в порядке.
Кто-нибудь знает, могу ли я предположить, что первый элемент в ожидающих сообщениях является самым ранним сообщением в PEL, а последнее сообщение — самым последним?
У меня есть приложение, которое я создал с использованием Spring Boot, и оно считывает данные из потока Redis. Я вызываю операцию xpending через API-интерфейс Spring Boot "opsForStream()" - это выглядит так:
private PendingMessages getPending() { return this.redisTransactionTemplate.opsForStream().pending(streamKey, groupName, Range.unbounded(), 1000); } Затем я хочу взять эти 1000 (или меньше) ожидающих сообщений и затем вызвать xrange. Однако я не уверен, что эти ожидающие сообщения расположены в порядке от самого раннего к последнему. В идеале я хочу использовать ожидающие сообщения по порядку, но не хочу предполагать, что они в порядке.
Кто-нибудь знает, могу ли я предположить, что первый элемент в ожидающих сообщениях является самым ранним сообщением в PEL, а последнее сообщение — самым последним?
Мобильная версия