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 and 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.