Package org.springframework.data.redis.stream

Interface Summary

Interface	Description
Cancelable	Cancelable allows stopping long running tasks and freeing underlying resources.
StreamListener<K,V extends Record<K,?>>	Listener interface to receive delivery of messages.
StreamMessageListenerContainer<K,V extends Record<K,?>>	Abstraction used by the framework representing a message listener container.
StreamReceiver<K,V extends Record<K,?>>	A receiver to consume Redis Streams using reactive infrastructure.
Subscription	The Subscription is the link to the actual running Task.
Task	The actual Task to run within the StreamMessageListenerContainer.

Class Summary

Class	Description
StreamMessageListenerContainer.ConsumerStreamReadRequest<K>	Request to read a Redis Stream with a Consumer.
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K>	Builder to build a StreamMessageListenerContainer.ConsumerStreamReadRequest.
StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V extends Record<K,?>>	Options for StreamMessageListenerContainer.
StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V extends Record<K,?>>	Builder for StreamMessageListenerContainer.StreamMessageListenerContainerOptions.
StreamMessageListenerContainer.StreamReadRequest<K>	Request to read a Redis Stream.
StreamMessageListenerContainer.StreamReadRequestBuilder<K>	Builder to build a StreamMessageListenerContainer.StreamReadRequest.
StreamReceiver.StreamReceiverOptions<K,V extends Record<K,?>>	Options for StreamReceiver.
StreamReceiver.StreamReceiverOptionsBuilder<K,V extends Record<K,?>>	Builder for StreamReceiver.StreamReceiverOptions.

Enum Summary

Enum	Description
Task.State	The Task.State defining the lifecycle phase the actual Task.