Class RedisListenerEndpointRegistry

java.lang.Object

org.springframework.data.redis.config.RedisListenerEndpointRegistry

All Implemented Interfaces:

Lifecycle, Phased, SmartLifecycle

public class RedisListenerEndpointRegistry
extends Object
implements SmartLifecycle

Creates the necessary RedisMessageListenerContainer instances for the registered endpoints.

Manages the lifecycle of the listener containers.

Since:

4.1

Author:

Ilyass Bougati

Field Summary

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
RedisListenerEndpointRegistry()

Method Summary

Modifier and Type	Method	Description
List<RedisListenerEndpoint>	getEndpoints()
boolean	isRunning()
void	registerListener(RedisListenerEndpoint endpoint, RedisMessageListenerContainer container)	Register a new RedisListenerEndpoint with the given RedisMessageListenerContainer.
void	start()
void	stop()

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

RedisListenerEndpointRegistry

public RedisListenerEndpointRegistry()

Method Details

registerListener

public void registerListener(RedisListenerEndpoint endpoint,
 RedisMessageListenerContainer container)

Register a new RedisListenerEndpoint with the given RedisMessageListenerContainer.

Parameters:

endpoint - the endpoint to register.

container - the container to register the endpoint with.

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

getEndpoints

public List<RedisListenerEndpoint> getEndpoints()