Package | Description |
---|---|
org.springframework.data.redis.stream |
Modifier and Type | Method and Description |
---|---|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.autoAck(boolean autoAck)
Deprecated.
since 2.3, use
autoAcknowledge(boolean) instead. |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.autoAcknowledge(boolean autoAck)
Configure auto-acknowledgement for stream message consumption.
|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.cancelOnError(Predicate<Throwable> cancelSubscriptionOnError)
Configure a cancellation
Predicate to be notified on read, deserialization, and listener
errors . |
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 read, deserialization, and listener errors . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.