Uses of Class
org.springframework.data.redis.connection.stream.RecordId
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of RecordId in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionstatic RecordId[]
ReactiveStreamCommands.AddStreamRecord.getMinId()
RedisStreamCommands.XAddOptions.getMinId()
default RecordId
DefaultedRedisConnection.xAdd
(MapRecord<byte[], byte[], byte[]> record, RedisStreamCommands.XAddOptions options) Deprecated.DefaultStringRedisConnection.xAdd
(MapRecord<byte[], byte[], byte[]> record, RedisStreamCommands.XAddOptions options) DefaultStringRedisConnection.xAdd
(StringRecord record, RedisStreamCommands.XAddOptions options) default RecordId
Append a new record with the givenfield/value pairs
as content to the stream stored atkey
.default RecordId
Append the givenrecord
to the stream stored atRecord#getStream
.RedisStreamCommands.xAdd
(MapRecord<byte[], byte[], byte[]> record, RedisStreamCommands.XAddOptions options) Append the givenrecord
to the stream stored atRecord#getStream
.default RecordId
Append a record to the streamkey
.default RecordId
StringRedisConnection.xAdd
(StringRecord record) Append the givenStringRecord
to the stream stored atRecord.getStream()
.StringRedisConnection.xAdd
(StringRecord record, RedisStreamCommands.XAddOptions options) Append the givenStringRecord
to the stream stored atRecord.getStream()
.Modifier and TypeMethodDescriptionRedisStreamCommands.XClaimOptions.getIds()
Get theList
of ID.ReactiveStreamCommands.AcknowledgeCommand.getRecordIds()
ReactiveStreamCommands.DeleteCommand.getRecordIds()
default reactor.core.publisher.Mono<RecordId>
ReactiveStreamCommands.xAdd
(ByteBuffer key, Map<ByteBuffer, ByteBuffer> body) Add stream record with given body to key.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,
RecordId>> ReactiveStreamCommands.xAdd
(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands) Add stream record with given body to key.default reactor.core.publisher.Mono<RecordId>
ReactiveStreamCommands.xAdd
(ByteBufferRecord record) Add stream record with given body to key.DefaultedRedisConnection.xClaimJustId
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xClaimJustId
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) DefaultStringRedisConnection.xClaimJustId
(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options) default reactor.core.publisher.Flux<RecordId>
ReactiveStreamCommands.xClaimJustId
(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,
reactor.core.publisher.Flux<RecordId>>> ReactiveStreamCommands.xClaimJustId
(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands) Change the ownership of a pending message to the given new consumer without increasing the delivered count.RedisStreamCommands.xClaimJustId
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.StringRedisConnection.xClaimJustId
(String key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.Modifier and TypeMethodDescriptionReactiveStreamCommands.AcknowledgeCommand.forRecords
(RecordId... recordIds) Applies the recordIds.Set the IDs to claim.ApplyMINID
trimming strategy, that evicts entries with IDs lower than the one specified.ApplyMINID
trimming strategy, that evicts entries with IDs lower than the one specified.Applies the recordIds.default Long
Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default reactor.core.publisher.Mono<Long>
ReactiveStreamCommands.xAck
(ByteBuffer key, String group, RecordId... recordIds) Acknowledge one or more records as processed.Acknowledge one or more records, identified via their id, as processed.default reactor.core.publisher.Flux<ByteBufferRecord>
ReactiveStreamCommands.xClaim
(ByteBuffer key, String group, String newOwner, Duration minIdleTime, RecordId... recordIds) Change the ownership of a pending message to the given new consumer.default List<ByteRecord>
RedisStreamCommands.xClaim
(byte[] key, String group, String newOwner, Duration minIdleTime, RecordId... recordIds) Change the ownership of a pending message to the given new consumer.default List<StringRecord>
StringRedisConnection.xClaim
(String key, String group, String newOwner, Duration minIdleTime, RecordId... recordIds) Change the ownership of a pending message to the given new consumer.default Long
Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default reactor.core.publisher.Mono<Long>
ReactiveStreamCommands.xDel
(ByteBuffer key, RecordId... recordIds) Removes the specified entries from the stream.Removes the records with the given id's from the stream. -
Uses of RecordId in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic RecordId
RecordId.autoGenerate()
Obtain theRecordId
signalling the server to auto generate an entry-id on insert (XADD
).PendingMessage.getId()
Record.getId()
The id of the entry inside the stream.PendingMessagesSummary.maxRecordId()
Get the greatest ID among the pending messages.PendingMessagesSummary.minRecordId()
Get the smallest ID among the pending messages.static RecordId
RecordId.of
(long millisecondsTime, long sequenceNumber) Create a new instance ofRecordId
using the provided String formatted as <millisecondsTime>-<sequenceNumber>.static RecordId
Obtain an instance ofRecordId
using the provided String formatted as <millisecondsTime>-<sequenceNumber>.Modifier and TypeMethodDescriptionstatic ReadOffset
Read all arriving elements from the stream starting atRecordId
.Configure aRecordId
.ModifierConstructorDescriptionPendingMessage
(RecordId id, Consumer consumer, Duration elapsedTimeSinceLastDelivery, long totalDeliveryCount) -
Uses of RecordId in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionAppend a record to the streamkey
.default RecordId
Append a record to the streamkey
.default RecordId
Append a record, backed by aMap
holding the field/value pairs, to the stream.Append the record, backed by the given value, to the stream.Modifier and TypeMethodDescriptiondefault reactor.core.publisher.Mono<RecordId>
Append a record to the streamkey
.default reactor.core.publisher.Flux<RecordId>
ReactiveStreamOperations.add
(K key, org.reactivestreams.Publisher<? extends Map<? extends HK, ? extends HV>> bodyPublisher) Append one or more records to the streamkey
.default reactor.core.publisher.Mono<RecordId>
Append a record, backed by aMap
holding the field/value pairs, to the stream.reactor.core.publisher.Mono<RecordId>
Append the record, backed by the given value, to the stream.Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Long>
ReactiveStreamOperations.acknowledge
(K key, String group, RecordId... recordIds) Acknowledge one or more records as processed.default Long
StreamOperations.acknowledge
(K key, String group, RecordId... recordIds) Acknowledge one or more records as processed.ReactiveStreamOperations.claim
(K key, String consumerGroup, String newOwner, Duration minIdleTime, RecordId... recordIds) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.StreamOperations.claim
(K key, String consumerGroup, String newOwner, Duration minIdleTime, RecordId... recordIds) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.reactor.core.publisher.Mono<Long>
Removes the specified records from the stream.Removes the specified records from the stream.
RedisCommandsProvider.streamCommands()
}.