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.TheSubscriptionis the link to the actual runningTask.The actualTaskto run within theStreamMessageListenerContainer.TheTask.Statedefining the lifecycle phase the actualTask.