Package | Description |
---|---|
org.springframework.data.redis.stream |
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)
|
<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.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.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.