public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> pollTimeout(Duration pollTimeout)
BLOCK
option during reading.pollTimeout
- must not be null or negative.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> batchSize(int messagesPerPoll)
COUNT
option during reading.messagesPerPoll
- must not be greater zero.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> executor(Executor executor)
executor
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> errorHandler(ErrorHandler errorHandler)
ErrorHandler
to be notified on errors
.errorHandler
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public <T> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<T,MapRecord<T,T,T>> serializer(RedisSerializer<T> serializer)
serializer
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public <NK,NV extends Record<NK,?>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK,NV> keySerializer(RedisSerializer<NK> serializer)
serializer
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public <HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>> hashKeySerializer(RedisSerializer<HK> serializer)
serializer
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public <HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>> hashValueSerializer(RedisSerializer<HV> serializer)
serializer
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>> targetType(Class<NV> targetType)
Record
type to ObjectRecord
.targetType
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>> objectMapper(HashMapper<NV,?,?> hashMapper)
Record
type to ObjectRecord
.hashMapper
- must not be null.this
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
.public StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V> build()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.