Package org.springframework.data.redis.stream
package org.springframework.data.redis.stream
-
ClassDescriptionCancelable allows stopping long running tasks and freeing underlying resources.StreamListener<K,
V extends Record<K, ?>> Listener interface to receive delivery ofmessages
.StreamMessageListenerContainer<K,V extends Record<K, ?>> Abstraction used by the framework representing a message listener container.Request to read a Redis Stream with aConsumer
.Builder to build aStreamMessageListenerContainer.ConsumerStreamReadRequest
.StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V extends Record<K, ?>> Options forStreamMessageListenerContainer
.StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V extends Record<K, ?>> Request to read a Redis Stream.Builder to build aStreamMessageListenerContainer.StreamReadRequest
.StreamReceiver<K,V extends Record<K, ?>> A receiver to consume Redis Streams using reactive infrastructure.StreamReceiver.StreamReceiverOptions<K,V extends Record<K, ?>> Options forStreamReceiver
.StreamReceiver.StreamReceiverOptionsBuilder<K,V extends Record<K, ?>> Builder forStreamReceiver.StreamReceiverOptions
.TheSubscription
is the link to the actual runningTask
.The actualTask
to run within theStreamMessageListenerContainer
.TheTask.State
defining the lifecycle phase the actualTask
.