Class ReactiveRedisMessageListenerContainer

All Implemented Interfaces:

public class ReactiveRedisMessageListenerContainer extends Object implements DisposableBean
Container providing a stream of ReactiveSubscription.ChannelMessage for messages received via Redis Pub/Sub listeners. The stream is infinite and registers Redis subscriptions. Handles the low level details of listening, converting and message dispatching.

Note the container allocates a single connection when it is created and releases the connection on destroy(). Connections are allocated eagerly to not interfere with non-blocking use during application operations. Using reactive infrastructure allows usage of a single connection due to channel multiplexing.

This class is thread-safe and allows subscription by multiple concurrent threads.

Mark Paluch, Christoph Strobl
See Also: