Class StreamMessageListenerContainer.StreamReadRequestBuilder<K>
java.lang.Object
org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamReadRequestBuilder<K>
- Type Parameters:
K
- Stream key and Stream field type.
- Direct Known Subclasses:
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
- Enclosing interface:
- StreamMessageListenerContainer<K,
V extends Record<K, ?>>
Builder to build a
StreamMessageListenerContainer.StreamReadRequest
.-
Method Summary
Modifier and TypeMethodDescriptionbuild()
Build a new instance ofStreamMessageListenerContainer.StreamReadRequest
.cancelOnError
(Predicate<Throwable> cancelSubscriptionOnError) Configure aConsumer
to consume stream messages within a consumer group.errorHandler
(org.springframework.util.ErrorHandler errorHandler) Configure aErrorHandler
to be notified onerrors
.
-
Method Details
-
errorHandler
public StreamMessageListenerContainer.StreamReadRequestBuilder<K> errorHandler(org.springframework.util.ErrorHandler errorHandler) Configure aErrorHandler
to be notified onerrors
.- Parameters:
errorHandler
- must not be null.- Returns:
this
StreamMessageListenerContainer.StreamReadRequestBuilder
.
-
cancelOnError
public StreamMessageListenerContainer.StreamReadRequestBuilder<K> cancelOnError(Predicate<Throwable> cancelSubscriptionOnError) Configure a cancellationPredicate
to be notified onerrors
. The outcome of thePredicate
decides whether to cancel the subscription by returning true.- Parameters:
cancelSubscriptionOnError
- must not be null.- Returns:
this
StreamMessageListenerContainer.StreamReadRequestBuilder
.
-
consumer
public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> consumer(Consumer consumer) Configure aConsumer
to consume stream messages within a consumer group.- Parameters:
consumer
- must not be null.- Returns:
- a new
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.
-
build
Build a new instance ofStreamMessageListenerContainer.StreamReadRequest
.- Returns:
- a new instance of
StreamMessageListenerContainer.StreamReadRequest
.
-