Class StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K, V extends Record<K,?>>
java.lang.Object
org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V>
- Type Parameters:
K- Stream key and Stream field type.V- Stream value type.
- Enclosing interface:
StreamMessageListenerContainer<K, V extends Record<K,?>>
public static class StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K, V extends Record<K,?>>
extends Object
Options for
StreamMessageListenerContainer.- Since:
- 2.2
- Author:
- Mark Paluch, Christoph Strobl, Christian Rest, DongCheol Kim, Su Ko
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionstatic StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String, MapRecord<String, String, String>> builder()Batch size polling using theCOUNToption during reads.@Nullable HashMapper<Object, Object, Object> getPhase()Timeout for blocking polling using theBLOCKoption during reads.boolean
-
Method Details
-
builder
public static StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<String, MapRecord<String,String, builder()String>> - Returns:
- a new builder for
StreamMessageListenerContainer.StreamMessageListenerContainerOptions.
-
getPollTimeout
Timeout for blocking polling using theBLOCKoption during reads.- Returns:
- the timeout.
-
getBatchSize
Batch size polling using theCOUNToption during reads.- Returns:
- the batch size.
-
getKeySerializer
-
getHashKeySerializer
-
getHashValueSerializer
-
getHashMapper
-
getRequiredHashMapper
-
hasHashMapper
public boolean hasHashMapper() -
getTargetType
-
getErrorHandler
- Returns:
- the default
ErrorHandler.
-
getExecutor
- Returns:
- the
Executorto run stream pollingTasks. Defaults toSimpleAsyncTaskExecutor.
-
getPhase
- Returns:
- the configured phase to use for the container lifecycle or
emptyif the phase was not specified on the options. - Since:
- 4.0
-
isAutoStartup
-