Class SubscriptionForwardingEndpointRegistry

java.lang.Object

org.springframework.data.redis.config.RedisListenerEndpointRegistry

org.springframework.data.redis.config.SubscriptionForwardingEndpointRegistry

All Implemented Interfaces:

Lifecycle, Phased, SmartLifecycle

public class SubscriptionForwardingEndpointRegistry
extends RedisListenerEndpointRegistry

RedisListenerEndpointRegistry that notifies listener beans implementing SubscriptionListener once per topic instead of once per registered endpoint.

Since:

4.2

Author:

Moritz Halbritter, Mark Paluch

Field Summary

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
SubscriptionForwardingEndpointRegistry()

Method Summary

Modifier and Type	Method	Description
void	registerListener(RedisListenerEndpoint endpoint, RedisMessageListenerContainer container)	Register a new RedisListenerEndpoint with the given RedisMessageListenerContainer.
void	start()
void	stop()

Methods inherited from class RedisListenerEndpointRegistry

getEndpoints, isRunning

Methods inherited from class Object

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

Methods inherited from interface SmartLifecycle

getPhase, isAutoStartup, isPauseable, stop

Constructor Details

SubscriptionForwardingEndpointRegistry

public SubscriptionForwardingEndpointRegistry()

Method Details

registerListener

public void registerListener(RedisListenerEndpoint endpoint,
 RedisMessageListenerContainer container)

Description copied from class: RedisListenerEndpointRegistry

Register a new RedisListenerEndpoint with the given RedisMessageListenerContainer.

Overrides:

registerListener in class RedisListenerEndpointRegistry

Parameters:

endpoint - the endpoint to register.

container - the container to register the endpoint with.

start

public void start()

Specified by:

start in interface Lifecycle

Overrides:

start in class RedisListenerEndpointRegistry

stop

public void stop()

Specified by:

stop in interface Lifecycle

Overrides:

stop in class RedisListenerEndpointRegistry