Uses of Class
org.springframework.data.redis.stream.StreamReceiver.StreamReceiverOptionsBuilder

Packages that use StreamReceiver.StreamReceiverOptionsBuilder

Package	Description
org.springframework.data.redis.stream

Uses of StreamReceiver.StreamReceiverOptionsBuilder in org.springframework.data.redis.stream

Methods in org.springframework.data.redis.stream that return StreamReceiver.StreamReceiverOptionsBuilder

Modifier and Type	Method	Description
StreamReceiver.StreamReceiverOptionsBuilder<K,V>	StreamReceiver.StreamReceiverOptionsBuilder.batchSize(int recordsPerPoll)	Configure a batch size for the COUNT option during reading.
static StreamReceiver.StreamReceiverOptionsBuilder<String,MapRecord<String,String,String>>	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.
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>>	StreamReceiver.StreamReceiverOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)	Configure a hash mapper.
StreamReceiver.StreamReceiverOptionsBuilder<K,V>	StreamReceiver.StreamReceiverOptionsBuilder.onErrorResume(Function<? super Throwable,? extends org.reactivestreams.Publisher<Void>> resumeFunction)	Configure a resume Function to resume the main sequence when polling the stream fails.
StreamReceiver.StreamReceiverOptionsBuilder<K,V>	StreamReceiver.StreamReceiverOptionsBuilder.pollTimeout(Duration pollTimeout)	Configure a poll timeout for the BLOCK 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.
<NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>>	StreamReceiver.StreamReceiverOptionsBuilder.targetType(Class<NV> targetType)	Configure a hash target type.