Class StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, V extends Record<K,?>>
java.lang.Object
org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V>
- Type Parameters:
K- Stream key and Stream field typeV- Stream value type
- Enclosing interface:
StreamMessageListenerContainer<K, V extends Record<K,?>>
-
Method Summary
Modifier and TypeMethodDescriptionautoStartup(boolean autoStartup) Configure the autoStartup to use for the containerSmartLifecyclebatchSize(int messagesPerPoll) Configure a batch size for theCOUNToption during reading.build()errorHandler(ErrorHandler errorHandler) Configure aErrorHandlerto be notified onerrors.<HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder <K, MapRecord<K, HK, HV>> hashKeySerializer(RedisSerializer<HK> serializer) Configure a hash key serializer.<HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder <K, MapRecord<K, HK, HV>> hashValueSerializer(RedisSerializer<HV> serializer) Configure a hash value serializer.<NK, NV extends Record<NK,?>>
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK, NV> keySerializer(RedisSerializer<NK> serializer) Configure a key serializer.<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, ObjectRecord<K, NV>> objectMapper(HashMapper<NV, ?, ?> hashMapper) Configure a hash mapper.phase(int phase) Configure the phase to use for the containerSmartLifecyclepollTimeout(Duration pollTimeout) Configure a poll timeout for theBLOCKoption during reading.<T> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<T, MapRecord<T, T, T>> serializer(RedisSerializer<T> serializer) Configure a key, hash key and hash value serializer.<NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, ObjectRecord<K, NV>> targetType(Class<NV> targetType) Configure a hash target type.
-
Method Details
-
pollTimeout
public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> pollTimeout(Duration pollTimeout) Configure a poll timeout for theBLOCKoption during reading.- Parameters:
pollTimeout- must not be null or negative.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
batchSize
public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> batchSize(int messagesPerPoll) Configure a batch size for theCOUNToption during reading.- Parameters:
messagesPerPoll- must not be greater zero.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
executor
public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> executor(Executor executor) - Parameters:
executor- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
errorHandler
public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> errorHandler(ErrorHandler errorHandler) Configure aErrorHandlerto be notified onerrors.- Parameters:
errorHandler- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
phase
public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> phase(int phase) Configure the phase to use for the containerSmartLifecycle- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.- Since:
- 4.0
-
autoStartup
public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> autoStartup(boolean autoStartup) Configure the autoStartup to use for the containerSmartLifecycle- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.- Since:
- 4.0
-
serializer
public <T> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<T, MapRecord<T,T, serializerT>> (RedisSerializer<T> serializer) Configure a key, hash key and hash value serializer.- Parameters:
serializer- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
keySerializer
public <NK, NV extends Record<NK,?>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK,NV> keySerializer(RedisSerializer<NK> serializer) Configure a key serializer.- Parameters:
serializer- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
hashKeySerializer
public <HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, MapRecord<K,HK, hashKeySerializerHV>> (RedisSerializer<HK> serializer) Configure a hash key serializer.- Parameters:
serializer- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
hashValueSerializer
public <HK,HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, MapRecord<K,HK, hashValueSerializerHV>> (RedisSerializer<HV> serializer) Configure a hash value serializer.- Parameters:
serializer- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
targetType
public <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, ObjectRecord<K,NV>> targetType(Class<NV> targetType) Configure a hash target type. Changes the emittedRecordtype toObjectRecord.- Parameters:
targetType- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
objectMapper
public <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, ObjectRecord<K,NV>> objectMapper(HashMapper<NV, ?, ?> hashMapper) Configure a hash mapper. Changes the emittedRecordtype toObjectRecord.- Parameters:
hashMapper- must not be null.- Returns:
thisStreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder.
-
build
-