Uses of Interface
org.springframework.data.redis.connection.stream.MapRecord
Packages that use MapRecord
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 MapRecord in org.springframework.data.redis.connection
Methods in org.springframework.data.redis.connection with parameters of type MapRecordModifier and TypeMethodDescriptiondefault RecordId
DefaultedRedisConnection.xAdd
(MapRecord<byte[], byte[], byte[]> record, RedisStreamCommands.XAddOptions options) Deprecated.DefaultStringRedisConnection.xAdd
(MapRecord<byte[], byte[], byte[]> record, RedisStreamCommands.XAddOptions options) 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
. -
Uses of MapRecord in org.springframework.data.redis.connection.stream
Subinterfaces of MapRecord in org.springframework.data.redis.connection.streamModifier 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
Methods in org.springframework.data.redis.connection.stream that return MapRecordModifier and TypeMethodDescriptionstatic <S,
K, V> MapRecord<S, K, V> default <K,
HK, HV> MapRecord<K, HK, HV> ByteBufferRecord.deserialize
(RedisSerializer<? extends K> streamSerializer, RedisSerializer<? extends HK> fieldSerializer, RedisSerializer<? extends HV> valueSerializer) Deserializekey
with the streamSerializer, field names with the fieldSerializer and values with the valueSerializer.default <T> MapRecord<T,
T, T> ByteBufferRecord.deserialize
(RedisSerializer<T> serializer) default <K,
HK, HV> MapRecord<K, HK, HV> ByteRecord.deserialize
(RedisSerializer<? extends K> streamSerializer, RedisSerializer<? extends HK> fieldSerializer, RedisSerializer<? extends HV> valueSerializer) Deserializekey
with the streamSerializer, field names with the fieldSerializer and values with the valueSerializer.default <T> MapRecord<T,
T, T> ByteRecord.deserialize
(RedisSerializer<T> serializer) default <SK,
HK, HV> MapRecord<SK, HK, HV> static <S,
K, V> MapRecord<S, K, V> Apply the givenmapFunction
to each and every entry in the backing collection to create a newMapRecord
.static <S,
K, V> MapRecord<S, K, V> Create aMapRecord
.ObjectRecord.toMapRecord
(HashMapper<? super V, HK, HV> mapper) Apply the givenHashMapper
to the backing value to create a newMapRecord
.MapRecord.withStreamKey
(SK key) Methods in org.springframework.data.redis.connection.stream with parameters of type MapRecordModifier and TypeMethodDescriptionstatic ByteBufferRecord
ByteBufferRecord.of
(MapRecord<ByteBuffer, ByteBuffer, ByteBuffer> source) Convert a binaryMapRecord
into aByteRecord
.static ByteRecord
Convert a binaryMapRecord
into aByteRecord
.static StringRecord
Method parameters in org.springframework.data.redis.connection.stream with type arguments of type MapRecord -
Uses of MapRecord in org.springframework.data.redis.core
Methods in org.springframework.data.redis.core that return MapRecordModifier and TypeMethodDescriptionReactiveStreamOperations.deserializeRecord
(ByteBufferRecord record) Deserialize aByteBufferRecord
using the configured serialization context into aMapRecord
.StreamOperations.deserializeRecord
(ByteRecord record) Deserialize aByteRecord
using the configured serializers into aMapRecord
.Methods in org.springframework.data.redis.core that return types with arguments of type MapRecordModifier and TypeMethodDescriptionReactiveStreamOperations.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.ReactiveStreamOperations.claim
(K key, String consumerGroup, String newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) 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.StreamOperations.claim
(K key, String consumerGroup, String newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.Read records from a stream within a specificRange
.Read records from a stream within a specificRange
.Read records from a stream within a specificRange
.BoundStreamOperations.read
(Consumer consumer, ReadOffset readOffset) Read records starting fromReadOffset
. using a consumer group.BoundStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset) Read records starting fromReadOffset
. using a consumer group.BoundStreamOperations.read
(ReadOffset readOffset) Read records fromReadOffset
.BoundStreamOperations.read
(StreamReadOptions readOptions, ReadOffset readOffset) Read records starting fromReadOffset
.ReactiveStreamOperations.read
(Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.ReactiveStreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.ReactiveStreamOperations.read
(StreamOffset<K> stream) Read records from aStreamOffset
asObjectRecord
.ReactiveStreamOperations.read
(StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.ReactiveStreamOperations.read
(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.StreamOperations.read
(Consumer consumer, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.StreamOperations.read
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s using a consumer group.StreamOperations.read
(StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.StreamOperations.read
(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or moreStreamOffset
s.BoundStreamOperations.reverseRange
(Range<String> range) Read records from a stream within a specificRange
in reverse order.BoundStreamOperations.reverseRange
(Range<String> range, Limit limit) ReactiveStreamOperations.reverseRange
(K key, Range<String> range) Read records from a stream within a specificRange
in reverse order.ReactiveStreamOperations.reverseRange
(K key, Range<String> range, Limit limit) StreamOperations.reverseRange
(K key, Range<String> range) Read records from a stream within a specificRange
in reverse order.StreamOperations.reverseRange
(K key, Range<String> range, Limit limit) Methods in org.springframework.data.redis.core with parameters of type MapRecordModifier and TypeMethodDescriptiondefault reactor.core.publisher.Mono<RecordId>
Append a record, backed by aMap
holding the field/value pairs, to the stream.default RecordId
Append a record, backed by aMap
holding the field/value pairs, to the stream.default <V> ObjectRecord<K,
V> Map records fromMapRecord
toObjectRecord
.default <V> ObjectRecord<K,
V> Map record fromMapRecord
toObjectRecord
.Method parameters in org.springframework.data.redis.core with type arguments of type MapRecord -
Uses of MapRecord in org.springframework.data.redis.stream
Methods in org.springframework.data.redis.stream that return types with arguments of type MapRecordModifier and TypeMethodDescriptionstatic StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String,
MapRecord<String, String, String>> StreamMessageListenerContainer.StreamMessageListenerContainerOptions.builder()
StreamReceiver.StreamReceiverOptions.builder()
StreamMessageListenerContainer.create
(RedisConnectionFactory connectionFactory) StreamReceiver.create
(ReactiveRedisConnectionFactory connectionFactory) <HK,
HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, MapRecord<K, HK, HV>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.hashKeySerializer
(RedisSerializer<HK> serializer) Configure a hash key serializer.<HK,
HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> StreamReceiver.StreamReceiverOptionsBuilder.hashKeySerializer
(RedisSerializationContext.SerializationPair<HK> pair) Configure a hash key serializer.<HK,
HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, MapRecord<K, HK, HV>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.hashValueSerializer
(RedisSerializer<HV> serializer) Configure a hash value serializer.<HK,
HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> StreamReceiver.StreamReceiverOptionsBuilder.hashValueSerializer
(RedisSerializationContext.SerializationPair<HV> pair) Configure a hash value serializer.StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.serializer
(RedisSerializer<T> serializer) Configure a key, hash key and hash value serializer.<T> StreamReceiver.StreamReceiverOptionsBuilder<T,
MapRecord<T, T, T>> StreamReceiver.StreamReceiverOptionsBuilder.serializer
(RedisSerializationContext.SerializationPair<T> pair) Configure a key, hash key and hash value serializer.<T> StreamReceiver.StreamReceiverOptionsBuilder<T,
MapRecord<T, T, T>> StreamReceiver.StreamReceiverOptionsBuilder.serializer
(RedisSerializationContext<T, ?> serializationContext) Configure a key, hash key and hash value serializer.
RedisCommandsProvider.streamCommands()
}.