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
|