Class RedisPubSubListenerRegistry

java.lang.Object

io.micronaut.configuration.lettuce.pubsub.RedisPubSubListenerRegistry

All Implemented Interfaces:

io.micronaut.runtime.graceful.GracefulShutdownCapable, AutoCloseable

@Singleton
@Requires(beans=AbstractRedisConfiguration.class)
public class RedisPubSubListenerRegistry
extends Object
implements AutoCloseable, io.micronaut.runtime.graceful.GracefulShutdownCapable

Manages Redis Pub/Sub listener registrations.

Since:

7.0

Author:

Graeme Rocher

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	RedisPubSubListenerRegistry.ChannelSubscription	A subscription target.

Constructor Summary

Constructors

Constructor	Description
RedisPubSubListenerRegistry(io.micronaut.context.BeanLocator beanLocator)

Method Summary

Modifier and Type	Method	Description
void	close()
OptionalLong	reportActiveTasks()
CompletionStage<?>	shutdownGracefully()
void	subscribe(@Nullable String connectionName, Set<RedisPubSubListenerRegistry.ChannelSubscription> subscriptions, ExecutorService executor, Consumer<RedisMessage> consumer)	Register a listener handler for the given channel subscriptions.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RedisPubSubListenerRegistry

public RedisPubSubListenerRegistry(io.micronaut.context.BeanLocator beanLocator)

Parameters:

beanLocator - The bean locator

Method Details

subscribe

public void subscribe(@Nullable String connectionName,
 Set<RedisPubSubListenerRegistry.ChannelSubscription> subscriptions,
 ExecutorService executor,
 Consumer<RedisMessage> consumer)

Register a listener handler for the given channel subscriptions.

Parameters:

connectionName - The optional connection name

subscriptions - The subscriptions

executor - The executor to invoke the listener on

consumer - The listener callback

shutdownGracefully

public CompletionStage<?> shutdownGracefully()

Specified by:

shutdownGracefully in interface io.micronaut.runtime.graceful.GracefulShutdownCapable

reportActiveTasks

public OptionalLong reportActiveTasks()

Specified by:

reportActiveTasks in interface io.micronaut.runtime.graceful.GracefulShutdownCapable

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable