K
- Stream key and Stream field type.V
- Stream value type.public static class StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V extends Record<K,?>> extends Object
StreamMessageListenerContainer
.Modifier and Type | Method and Description |
---|---|
static StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String,MapRecord<String,String,String>> |
builder() |
OptionalInt |
getBatchSize()
Batch size polling using the
COUNT option during reads. |
ErrorHandler |
getErrorHandler() |
Executor |
getExecutor() |
RedisSerializer<Object> |
getHashKeySerializer() |
HashMapper<Object,Object,Object> |
getHashMapper() |
RedisSerializer<Object> |
getHashValueSerializer() |
RedisSerializer<K> |
getKeySerializer() |
Duration |
getPollTimeout()
Timeout for blocking polling using the
BLOCK option during reads. |
Class<Object> |
getTargetType() |
public static StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String,MapRecord<String,String,String>> builder()
StreamMessageListenerContainer.StreamMessageListenerContainerOptions
.public Duration getPollTimeout()
BLOCK
option during reads.public OptionalInt getBatchSize()
COUNT
option during reads.public RedisSerializer<K> getKeySerializer()
public RedisSerializer<Object> getHashKeySerializer()
public RedisSerializer<Object> getHashValueSerializer()
@Nullable public HashMapper<Object,Object,Object> getHashMapper()
public ErrorHandler getErrorHandler()
ErrorHandler
.public Executor getExecutor()
Executor
to run stream polling Task
s. Defaults to SimpleAsyncTaskExecutor
.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.