Uses of Class
org.springframework.data.redis.stream.StreamReceiver.StreamReceiverOptionsBuilder
-
Uses of StreamReceiver.StreamReceiverOptionsBuilder in org.springframework.data.redis.stream
Modifier and TypeMethodDescriptionStreamReceiver.StreamReceiverOptionsBuilder.batchSize
(int recordsPerPoll) Configure a batch size for theCOUNT
option during reading.StreamReceiver.StreamReceiverOptions.builder()
static <T> StreamReceiver.StreamReceiverOptionsBuilder<String,
ObjectRecord<String, T>> StreamReceiver.StreamReceiverOptions.builder
(HashMapper<T, byte[], byte[]> hashMapper) <HK,
HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> StreamReceiver.StreamReceiverOptionsBuilder.hashKeySerializer
(RedisSerializationContext.SerializationPair<HK> pair) Configure a hash key serializer.<HK,
HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> StreamReceiver.StreamReceiverOptionsBuilder.hashValueSerializer
(RedisSerializationContext.SerializationPair<HV> pair) Configure a hash value serializer.<NK,
NV extends Record<NK, ?>>
StreamReceiver.StreamReceiverOptionsBuilder<NK,NV> StreamReceiver.StreamReceiverOptionsBuilder.keySerializer
(RedisSerializationContext.SerializationPair<NK> pair) Configure a key serializer.StreamReceiver.StreamReceiverOptionsBuilder.objectMapper
(HashMapper<NV, ?, ?> hashMapper) Configure a hash mapper.StreamReceiver.StreamReceiverOptionsBuilder.onErrorResume
(Function<? super Throwable, ? extends org.reactivestreams.Publisher<Void>> resumeFunction) Configure a resumeFunction
to resume the main sequence when polling the stream fails.StreamReceiver.StreamReceiverOptionsBuilder.pollTimeout
(Duration pollTimeout) Configure a poll timeout for theBLOCK
option during reading.<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.StreamReceiver.StreamReceiverOptionsBuilder.targetType
(Class<NV> targetType) Configure a hash target type.