Package org.springframework.data.redis.stream
package org.springframework.data.redis.stream
-
ClassDescriptionCancelable allows stopping long running tasks and freeing underlying resources.Listener interface to receive delivery of
messages
.Abstraction used by the framework representing a message listener container.Request to read a Redis Stream with aConsumer
.Builder to build aStreamMessageListenerContainer.ConsumerStreamReadRequest
.Options forStreamMessageListenerContainer
.StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K, V extends Record<K,?>> Request to read a Redis Stream.Builder to build aStreamMessageListenerContainer.StreamReadRequest
.A receiver to consume Redis Streams using reactive infrastructure.Options forStreamReceiver
.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
.