Uses of Class
org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder

Packages that use StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder

Package	Description
org.springframework.data.redis.stream

Uses of StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder in org.springframework.data.redis.stream

Methods in org.springframework.data.redis.stream that return StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder

Modifier and Type	Method	Description
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.batchSize(int messagesPerPoll)	Configure a batch size for the COUNT option during reading.
static StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String,MapRecord<String,String,String>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptions.builder()
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.errorHandler(ErrorHandler errorHandler)	Configure a ErrorHandler to be notified on errors.
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.executor(Executor executor)	Configure a Executor to run stream polling Tasks.
<HK, HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.hashKeySerializer(RedisSerializer<HK> serializer)	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.
<NK, NV extends Record<NK, ?>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK,NV>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.keySerializer(RedisSerializer<NK> serializer)	Configure a key serializer.
<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.objectMapper(HashMapper<NV,?,?> hashMapper)	Configure a hash mapper.
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.pollTimeout(Duration pollTimeout)	Configure a poll timeout for the BLOCK option during reading.
<T> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<T,MapRecord<T,T,T>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.serializer(RedisSerializer<T> serializer)	Configure a key, hash key and hash value serializer.
<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>>	StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.targetType(Class<NV> targetType)	Configure a hash target type.