K
- Stream key and Stream field type.public static class StreamMessageListenerContainer.StreamReadRequestBuilder<K> extends Object
StreamMessageListenerContainer.StreamReadRequest
.Modifier and Type | Method and Description |
---|---|
StreamMessageListenerContainer.StreamReadRequest<K> |
build()
Build a new instance of
StreamMessageListenerContainer.StreamReadRequest . |
StreamMessageListenerContainer.StreamReadRequestBuilder<K> |
cancelOnError(Predicate<Throwable> cancelSubscriptionOnError)
|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
consumer(Consumer consumer)
Configure a
Consumer to consume stream messages within a consumer group. |
StreamMessageListenerContainer.StreamReadRequestBuilder<K> |
errorHandler(ErrorHandler errorHandler)
Configure a
ErrorHandler to be notified on errors . |
public StreamMessageListenerContainer.StreamReadRequestBuilder<K> errorHandler(ErrorHandler errorHandler)
ErrorHandler
to be notified on errors
.errorHandler
- must not be null.this
StreamMessageListenerContainer.StreamReadRequestBuilder
.public StreamMessageListenerContainer.StreamReadRequestBuilder<K> cancelOnError(Predicate<Throwable> cancelSubscriptionOnError)
Predicate
to be notified on errors
. The outcome of the
Predicate
decides whether to cancel the subscription by returning true.cancelSubscriptionOnError
- must not be null.this
StreamMessageListenerContainer.StreamReadRequestBuilder
.public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> consumer(Consumer consumer)
Consumer
to consume stream messages within a consumer group.consumer
- must not be null.StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.public StreamMessageListenerContainer.StreamReadRequest<K> build()
StreamMessageListenerContainer.StreamReadRequest
.StreamMessageListenerContainer.StreamReadRequest
.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.