Uses of Interface
org.springframework.data.redis.connection.stream.Record

Packages that use Record

Package	Description
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.
org.springframework.data.redis.stream

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

Subinterfaces of Record in org.springframework.data.redis.connection.stream

Modifier and Type	Interface	Description
interface	ByteBufferRecord	A Record within the stream backed by a collection of binary field/value pairs.
interface	ByteRecord	A Record within the stream backed by a collection of binary field/value pairs.
interface	MapRecord<S,K,V>	A Record within the stream backed by a collection of field/value pairs.
interface	ObjectRecord<S,V>	A Record within the stream mapped to a single object.
interface	StringRecord	A Record within the stream backed by a collection of String field/value pairs.

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

Modifier and Type	Method	Description
Record<S,V>	Record.withId(RecordId id)	Create a new instance of Record with the given RecordId.
<SK> Record<SK,V>	Record.withStreamKey(SK key)	Create a new instance of Record with the given key to store the record at.

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

Modifier and Type	Method	Description
static <K> StreamOffset<K>	StreamOffset.from(Record<K,?> reference)	Create a StreamOffset from the given record id as reference to create the ReadOffset.from(String).

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

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

Modifier and Type	Method	Description
default Mono<Long>	ReactiveStreamOperations.acknowledge(@NonNull String group, @NonNull Record<K,?> record)	Acknowledge the given record as processed.
default Long	StreamOperations.acknowledge(@NonNull String group, @NonNull Record<@NonNull K, ?> record)	Acknowledge the given record as processed.
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.
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.
default Mono<Long>	ReactiveStreamOperations.delete(@NonNull Record<K,?> record)	Removes a given Record from the stream.
default Long	StreamOperations.delete(@NonNull Record<K,?> record)	Removes a given Record from the stream.

Uses of Record in org.springframework.data.redis.stream

Classes in org.springframework.data.redis.stream with type parameters of type Record

Modifier and Type	Interface	Description
interface	StreamListener<K, V extends Record<K,?>>	Listener interface to receive delivery of messages.
interface	StreamMessageListenerContainer<K, V extends Record<K,?>>	Abstraction used by the framework representing a message listener container.
static class	StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K, V extends Record<K,?>>	Options for StreamMessageListenerContainer.
static class	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, V extends Record<K,?>>	Builder for StreamMessageListenerContainer.StreamMessageListenerContainerOptions.
interface	StreamReceiver<K, V extends Record<K,?>>	A receiver to consume Redis Streams using reactive infrastructure.
static class	StreamReceiver.StreamReceiverOptions<K, V extends Record<K,?>>	Options for StreamReceiver.
static class	StreamReceiver.StreamReceiverOptionsBuilder<K, V extends Record<K,?>>	Builder for StreamReceiver.StreamReceiverOptions.

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

Modifier and Type	Method	Description
static <K, V extends Record<K,?>> StreamMessageListenerContainer<K,V>	StreamMessageListenerContainer.create(RedisConnectionFactory connectionFactory, StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V> options)	Create a new StreamMessageListenerContainer given RedisConnectionFactory and StreamMessageListenerContainer.StreamMessageListenerContainerOptions.
static <K, V extends Record<K,?>> StreamReceiver<K,V>	StreamReceiver.create(ReactiveRedisConnectionFactory connectionFactory, StreamReceiver.StreamReceiverOptions<K,V> options)	Create a new StreamReceiver given ReactiveRedisConnectionFactory and StreamReceiver.StreamReceiverOptions.
<NK, NV extends Record<NK,?>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK,NV>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.keySerializer(RedisSerializer<NK> serializer)	Configure a key serializer.
<NK, NV extends Record<NK,?>> StreamReceiver.StreamReceiverOptionsBuilder<NK,NV>	StreamReceiver.StreamReceiverOptionsBuilder.keySerializer(RedisSerializationContext.SerializationPair<NK> pair)	Configure a key serializer.