K
- Stream key and Stream field type.public static class StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> extends StreamMessageListenerContainer.StreamReadRequestBuilder<K>
StreamMessageListenerContainer.ConsumerStreamReadRequest
.public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> errorHandler(ErrorHandler errorHandler)
ErrorHandler
to be notified on read, deserialization, and listener errors
.errorHandler
in class StreamMessageListenerContainer.StreamReadRequestBuilder<K>
errorHandler
- must not be null.this
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> cancelOnError(Predicate<Throwable> cancelSubscriptionOnError)
Predicate
to be notified on read, deserialization, and listener
errors
. The outcome of the Predicate
decides whether to cancel the subscription by returning
true.cancelOnError
in class StreamMessageListenerContainer.StreamReadRequestBuilder<K>
cancelSubscriptionOnError
- must not be null.this
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> consumer(Consumer consumer)
Consumer
to consume stream messages within a consumer group.consumer
in class StreamMessageListenerContainer.StreamReadRequestBuilder<K>
consumer
- must not be null.this
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.@Deprecated public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> autoAck(boolean autoAck)
autoAcknowledge(boolean)
instead.autoAck
- true (default) to auto-acknowledge received messages or false for external
acknowledgement.this
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> autoAcknowledge(boolean autoAck)
autoAck(boolean)
for improved readability.autoAck
- true (default) to auto-acknowledge received messages or false for external
acknowledgement.this
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
.public StreamMessageListenerContainer.ConsumerStreamReadRequest<K> build()
StreamMessageListenerContainer.ConsumerStreamReadRequest
.build
in class StreamMessageListenerContainer.StreamReadRequestBuilder<K>
StreamMessageListenerContainer.ConsumerStreamReadRequest
.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.