| Cancelable
Cancelable allows stopping long running tasks and freeing underlying resources.
|
StreamListener
Listener interface to receive delivery of messages.
|
| StreamMessageListenerContainer
Abstraction used by the framework representing a message listener container.
|
StreamMessageListenerContainer.ConsumerStreamReadRequest
Request to read a Redis Stream with a Consumer.
|
| StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder
|
| StreamMessageListenerContainer.StreamMessageListenerContainerOptions
|
| StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder
|
| StreamMessageListenerContainer.StreamReadRequest
Request to read a Redis Stream.
|
| StreamMessageListenerContainer.StreamReadRequestBuilder
|
| StreamReceiver
A receiver to consume Redis Streams using reactive infrastructure.
|
| StreamReceiver.StreamReceiverOptions
|
| StreamReceiver.StreamReceiverOptionsBuilder
|
| Subscription
|
| Task.State
|