Uses of Class
org.springframework.data.redis.connection.stream.RecordId

Packages that use RecordId

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.connection.stream	Data structures and interfaces to interact with Redis Streams.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.

Uses of RecordId in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return RecordId

Modifier and Type	Method	Description
static RecordId[]	StringRedisConnection.entryIds(String... entryIds)
@Nullable RecordId	ReactiveStreamCommands.AddStreamRecord.getMinId()
@Nullable RecordId	RedisStreamCommands.XAddOptions.getMinId()
default RecordId	DefaultedRedisConnection.xAdd(MapRecord<byte[],byte[],byte[]> record, RedisStreamCommands.XAddOptions options)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
RecordId	DefaultStringRedisConnection.xAdd(MapRecord<byte[],byte[],byte[]> record, RedisStreamCommands.XAddOptions options)
RecordId	DefaultStringRedisConnection.xAdd(StringRecord record, RedisStreamCommands.XAddOptions options)
default RecordId	RedisStreamCommands.xAdd(byte @NonNull [] key, @NonNull Map<byte @NonNull [], byte @NonNull []> content)	Append a new record with the given field/value pairs as content to the stream stored at key.
default RecordId	RedisStreamCommands.xAdd(@NonNull MapRecord<byte[],byte[],byte[]> record)	Append the given record to the stream stored at Record#getStream.
RecordId	RedisStreamCommands.xAdd(MapRecord<byte[],byte[],byte[]> record, @NonNull RedisStreamCommands.XAddOptions options)	Append the given record to the stream stored at Record#getStream.
default RecordId	StringRedisConnection.xAdd(@NonNull String key, @NonNull Map<@NonNull String, String> body)	Append a record to the stream key.
default RecordId	StringRedisConnection.xAdd(@NonNull StringRecord record)	Append the given StringRecord to the stream stored at Record.getStream().
RecordId	StringRedisConnection.xAdd(@NonNull StringRecord record, @NonNull RedisStreamCommands.XAddOptions options)	Append the given StringRecord to the stream stored at Record.getStream().

Methods in org.springframework.data.redis.connection that return types with arguments of type RecordId

Modifier and Type	Method	Description
List<RecordId>	RedisStreamCommands.XClaimOptions.getIds()	Get the List of ID.
List<RecordId>	ReactiveStreamCommands.AcknowledgeCommand.getRecordIds()
List<RecordId>	ReactiveStreamCommands.DeleteCommand.getRecordIds()
default Mono<RecordId>	ReactiveStreamCommands.xAdd(ByteBuffer key, Map<ByteBuffer, ByteBuffer> body)	Add stream record with given body to key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord, RecordId>>	ReactiveStreamCommands.xAdd(Publisher<ReactiveStreamCommands.AddStreamRecord> commands)	Add stream record with given body to key.
default Mono<RecordId>	ReactiveStreamCommands.xAdd(ByteBufferRecord record)	Add stream record with given body to key.
default Mono<RecordId>	ReactiveStreamCommands.xAdd(ByteBufferRecord record, RedisStreamCommands.XAddOptions xAddOptions)	Add stream record with the specified options.
default List<RecordId>	DefaultedRedisConnection.xClaimJustId(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
List<RecordId>	DefaultStringRedisConnection.xClaimJustId(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options)
List<RecordId>	DefaultStringRedisConnection.xClaimJustId(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options)
default 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.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand, Flux<RecordId>>>	ReactiveStreamCommands.xClaimJustId(Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.
List<@NonNull RecordId>	RedisStreamCommands.xClaimJustId(byte @NonNull [] key, @NonNull String group, @NonNull String newOwner, @NonNull RedisStreamCommands.XClaimOptions options)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.
List<RecordId>	StringRedisConnection.xClaimJustId(@NonNull String key, @NonNull String group, @NonNull String newOwner, @NonNull RedisStreamCommands.XClaimOptions options)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.

Methods in org.springframework.data.redis.connection with parameters of type RecordId

Modifier and Type	Method	Description
ReactiveStreamCommands.AcknowledgeCommand	ReactiveStreamCommands.AcknowledgeCommand.forRecords(RecordId... recordIds)	Applies the recordIds.
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder.ids(RecordId... ids)	Set the IDs to claim.
ReactiveStreamCommands.AddStreamRecord	ReactiveStreamCommands.AddStreamRecord.minId(RecordId minId)	Apply MINID trimming strategy, that evicts entries with IDs lower than the one specified.
RedisStreamCommands.XAddOptions	RedisStreamCommands.XAddOptions.minId(RecordId minId)	Apply MINID trimming strategy, that evicts entries with IDs lower than the one specified.
ReactiveStreamCommands.DeleteCommand	ReactiveStreamCommands.DeleteCommand.records(RecordId... recordIds)	Applies the recordIds.
default Long	DefaultedRedisConnection.xAck(byte[] key, String group, RecordId... messageIds)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
Long	DefaultStringRedisConnection.xAck(byte[] key, String group, RecordId... recordIds)
Long	DefaultStringRedisConnection.xAck(String key, String group, RecordId... recordIds)
default Mono<Long>	ReactiveStreamCommands.xAck(ByteBuffer key, String group, RecordId... recordIds)	Acknowledge one or more records as processed.
Long	RedisStreamCommands.xAck(byte @NonNull [] key, @NonNull String group, @NonNull RecordId @NonNull ... recordIds)	Acknowledge one or more records, identified via their id, as processed.
Long	StringRedisConnection.xAck(@NonNull String key, @NonNull String group, @NonNull RecordId @NonNull ... recordIds)
default 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<@NonNull ByteRecord>	RedisStreamCommands.xClaim(byte @NonNull [] key, @NonNull String group, @NonNull String newOwner, @NonNull Duration minIdleTime, @NonNull RecordId @NonNull ... recordIds)	Change the ownership of a pending message to the given new consumer.
default List<StringRecord>	StringRedisConnection.xClaim(@NonNull String key, @NonNull String group, @NonNull String newOwner, @NonNull Duration minIdleTime, @NonNull RecordId @NonNull ... recordIds)	Change the ownership of a pending message to the given new consumer.
default Long	DefaultedRedisConnection.xDel(byte[] key, RecordId... recordIds)	Deprecated. in favor of RedisCommandsProvider.streamCommands()}.
Long	DefaultStringRedisConnection.xDel(byte[] key, RecordId... recordIds)
Long	DefaultStringRedisConnection.xDel(String key, RecordId... recordIds)
default Mono<Long>	ReactiveStreamCommands.xDel(ByteBuffer key, RecordId... recordIds)	Removes the specified entries from the stream.
Long	RedisStreamCommands.xDel(byte @NonNull [] key, @NonNull RecordId @NonNull ... recordIds)	Removes the records with the given id's from the stream.
Long	StringRedisConnection.xDel(@NonNull String key, @NonNull RecordId @NonNull ... recordIds)

Uses of RecordId in org.springframework.data.redis.connection.stream

Methods in org.springframework.data.redis.connection.stream that return RecordId

Modifier and Type	Method	Description
static RecordId	RecordId.autoGenerate()	Obtain the RecordId signalling the server to auto generate an entry-id on insert (XADD).
RecordId	PendingMessage.getId()
RecordId	Record.getId()	The id of the entry inside the stream.
RecordId	PendingMessagesSummary.maxRecordId()	Get the greatest ID among the pending messages.
RecordId	PendingMessagesSummary.minRecordId()	Get the smallest ID among the pending messages.
static RecordId	RecordId.of(long millisecondsTime, long sequenceNumber)	Create a new instance of RecordId using the provided String formatted as <millisecondsTime>-<sequenceNumber>.
static RecordId	RecordId.of(@Nullable String value)	Obtain an instance of RecordId using the provided String formatted as <millisecondsTime>-<sequenceNumber>.

Methods in org.springframework.data.redis.connection.stream with parameters of type RecordId

Modifier and Type	Method	Description
static ReadOffset	ReadOffset.from(RecordId offset)	Read all arriving elements from the stream starting at RecordId.
ByteBufferRecord	ByteBufferRecord.withId(RecordId id)
ByteRecord	ByteRecord.withId(RecordId id)
MapRecord<S,K,V>	MapRecord.withId(RecordId id)
ObjectRecord<S,V>	ObjectRecord.withId(RecordId id)
Record<S,V>	Record.withId(RecordId id)	Create a new instance of Record with the given RecordId.
StreamRecords.RecordBuilder<S>	StreamRecords.RecordBuilder.withId(RecordId id)	Configure a RecordId.
StringRecord	StringRecord.withId(RecordId id)

Constructors in org.springframework.data.redis.connection.stream with parameters of type RecordId

Modifier	Constructor	Description
	PendingMessage(RecordId id, Consumer consumer, Duration elapsedTimeSinceLastDelivery, long totalDeliveryCount)

Uses of RecordId in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core that return RecordId

Modifier and Type	Method	Description
RecordId	BoundStreamOperations.add(@NonNull Map<@NonNull HK, HV> body)	Append a record to the stream key.
RecordId	BoundStreamOperations.add(@NonNull Map<@NonNull HK, HV> content, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append a record to the stream key with the specified options.
default RecordId	StreamOperations.add(@NonNull K key, @NonNull Map<? extends @NonNull HK, ? extends HV> content)	Append a record to the stream key.
default RecordId	StreamOperations.add(@NonNull K key, @NonNull Map<? extends @NonNull HK, ? extends HV> content, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append a record to the stream key with the specified options.
default RecordId	StreamOperations.add(@NonNull MapRecord<K, ? extends HK, ? extends HV> record)	Append a record, backed by a Map holding the field/value pairs, to the stream.
default RecordId	StreamOperations.add(@NonNull MapRecord<K, ? extends HK, ? extends HV> record, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append a record, backed by a Map holding the field/value pairs, to the stream with the specified options.
RecordId	StreamOperations.add(@NonNull Record<K,?> record)	Append the record, backed by the given value, to the stream.
RecordId	StreamOperations.add(@NonNull Record<K,?> record, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append the record, backed by the given value, to the stream with the specified options.

Methods in org.springframework.data.redis.core that return types with arguments of type RecordId

Modifier and Type	Method	Description
default Mono<RecordId>	ReactiveStreamOperations.add(@NonNull K key, @NonNull Map<? extends HK, ? extends HV> content)	Append a record to the stream key.
default Mono<RecordId>	ReactiveStreamOperations.add(@NonNull K key, @NonNull Map<? extends HK, ? extends HV> content, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append a record to the stream key with the specified options.
default Flux<RecordId>	ReactiveStreamOperations.add(@NonNull K key, @NonNull Publisher<? extends Map<? extends HK, ? extends HV>> bodyPublisher)	Append one or more records to the stream key.
default Mono<RecordId>	ReactiveStreamOperations.add(@NonNull MapRecord<K, ? extends HK, ? extends HV> record)	Append a record, backed by a Map holding the field/value pairs, to the stream.
default Mono<RecordId>	ReactiveStreamOperations.add(@NonNull MapRecord<K, ? extends HK, ? extends HV> record, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append a record, backed by a Map holding the field/value pairs, to the stream with the specified options.
Mono<RecordId>	ReactiveStreamOperations.add(@NonNull Record<K,?> record)	Append the record, backed by the given value, to the stream.
Mono<RecordId>	ReactiveStreamOperations.add(@NonNull Record<K,?> record, @NonNull RedisStreamCommands.XAddOptions xAddOptions)	Append the record, backed by the given value, to the stream with the specified options.

Methods in org.springframework.data.redis.core with parameters of type RecordId

Modifier and Type	Method	Description
Mono<Long>	ReactiveStreamOperations.acknowledge(@NonNull K key, @NonNull String group, @NonNull RecordId @NonNull ... recordIds)	Acknowledge one or more records as processed.
default Long	StreamOperations.acknowledge(@NonNull K key, @NonNull String group, @NonNull RecordId @NonNull ... recordIds)	Acknowledge one or more records as processed.
default Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.claim(@NonNull K key, @NonNull String consumerGroup, @NonNull String newOwner, @NonNull Duration minIdleTime, @NonNull RecordId @NonNull ... recordIds)	Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.
default List<@NonNull MapRecord<K,HK,HV>>	StreamOperations.claim(@NonNull K key, @NonNull String consumerGroup, @NonNull String newOwner, @NonNull Duration minIdleTime, @NonNull RecordId @NonNull ... recordIds)	Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.
Mono<Long>	ReactiveStreamOperations.delete(@NonNull K key, @NonNull RecordId @NonNull ... recordIds)	Removes the specified records from the stream.
Long	StreamOperations.delete(@NonNull K key, @NonNull RecordId @NonNull ... recordIds)	Removes the specified records from the stream.