Uses of Interface
org.springframework.data.redis.connection.stream.Record
Package
Description
Data structures and interfaces to interact with Redis Streams.
Core package for integrating Redis with Spring concepts.
-
Uses of Record in org.springframework.data.redis.connection.stream
Modifier and TypeInterfaceDescriptioninterface
ARecord
within the stream backed by a collection of binary field/value pairs.interface
ARecord
within the stream backed by a collection of binary field/value pairs.interface
MapRecord<S,
K, V> ARecord
within the stream backed by a collection of field/value pairs.interface
ObjectRecord<S,
V> ARecord
within the stream mapped to a single object.interface
Modifier and TypeMethodDescriptionRecord.withStreamKey
(SK key) Create a new instance ofRecord
with the given key to store the record at. -
Uses of Record in org.springframework.data.redis.core
Modifier and TypeMethodDescriptiondefault reactor.core.publisher.Mono<Long>
ReactiveStreamOperations.acknowledge
(String group, Record<K, ?> record) Acknowledge the given record as processed.default Long
StreamOperations.acknowledge
(String group, Record<K, ?> record) Acknowledge the given record as processed.reactor.core.publisher.Mono<RecordId>
Append the record, backed by the given value, to the stream.Append the record, backed by the given value, to the stream.default reactor.core.publisher.Mono<Long>
Removes a givenRecord
from the stream.default Long
Removes a givenRecord
from the stream. -
Uses of Record in org.springframework.data.redis.stream
Modifier and TypeInterfaceDescriptioninterface
StreamListener<K,
V extends Record<K, ?>> Listener interface to receive delivery ofmessages
.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 forStreamMessageListenerContainer
.static class
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,
V extends Record<K, ?>> 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 forStreamReceiver
.static class
StreamReceiver.StreamReceiverOptionsBuilder<K,
V extends Record<K, ?>> Builder forStreamReceiver.StreamReceiverOptions
.Modifier and TypeMethodDescriptionstatic <K,
V extends Record<K, ?>>
StreamMessageListenerContainer<K,V> StreamMessageListenerContainer.create
(RedisConnectionFactory connectionFactory, StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K, V> options) static <K,
V extends Record<K, ?>>
StreamReceiver<K,V> StreamReceiver.create
(ReactiveRedisConnectionFactory connectionFactory, StreamReceiver.StreamReceiverOptions<K, V> options) Create a newStreamReceiver
givenReactiveRedisConnectionFactory
andStreamReceiver.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.