Package | Description |
---|---|
org.springframework.data.redis.stream |
Modifier and Type | Method and Description |
---|---|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.autoAck(boolean autoAck)
Configure auto-acknowledgement for stream message consumption.
|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.cancelOnError(Predicate<Throwable> cancelSubscriptionOnError)
|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.StreamReadRequestBuilder.consumer(Consumer consumer)
Configure a
Consumer to consume stream messages within a consumer group. |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.consumer(Consumer consumer)
Configure a
Consumer to consume stream messages within a consumer group. |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.errorHandler(ErrorHandler errorHandler)
Configure a
ErrorHandler to be notified on errors . |
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.