K
- Stream key and Stream field type.public static class StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> extends StreamMessageListenerContainer.StreamReadRequestBuilder<K>
StreamMessageListenerContainer.ConsumerStreamReadRequest
.Modifier and Type | Method and Description |
---|---|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
autoAck(boolean autoAck)
Configure auto-acknowledgement for stream message consumption.
|
StreamMessageListenerContainer.ConsumerStreamReadRequest<K> |
build()
Build a new instance of
StreamMessageListenerContainer.ConsumerStreamReadRequest . |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
cancelOnError(Predicate<Throwable> cancelSubscriptionOnError)
|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
consumer(Consumer consumer)
Configure a
Consumer to consume stream messages within a consumer group. |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
errorHandler(ErrorHandler errorHandler)
Configure a
ErrorHandler to be notified on errors . |
public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> errorHandler(ErrorHandler errorHandler)
ErrorHandler
to be notified on 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 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
.public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> autoAck(boolean autoAck)
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–2020 Pivotal Software, Inc.. All rights reserved.