Class SimpleRedisListenerEndpoint

java.lang.Object

org.springframework.data.redis.config.AbstractRedisListenerEndpoint

org.springframework.data.redis.config.SimpleRedisListenerEndpoint

All Implemented Interfaces:

Lifecycle, Phased, SmartLifecycle, RedisListenerEndpoint

public class SimpleRedisListenerEndpoint
extends AbstractRedisListenerEndpoint

A RedisListenerEndpoint simply providing the MessageListener to invoke to process an incoming message for this endpoint.

Since:

4.1

Author:

Mark Paluch

Field Summary

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
SimpleRedisListenerEndpoint()
SimpleRedisListenerEndpoint(MessageListener messageListener)

Method Summary

Modifier and Type	Method	Description
protected @Nullable MessageListener	createListener()	Create the MessageListener for this endpoint.
protected StringBuilder	getEndpointDescription()	Return a description for this endpoint.
@Nullable MessageListener	getMessageListener()	Return the MessageListener to invoke when a message matching the endpoint is received.
void	setMessageListener(@Nullable MessageListener messageListener)	Set the MessageListener to invoke when a message matching the endpoint is received.

Methods inherited from class AbstractRedisListenerEndpoint

getId, getTopic, isRunning, register, setId, setTopic, start, stop, toString

Methods inherited from class Object

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

Methods inherited from interface SmartLifecycle

getPhase, isAutoStartup, isPauseable, stop

Constructor Details

SimpleRedisListenerEndpoint

public SimpleRedisListenerEndpoint()

SimpleRedisListenerEndpoint

public SimpleRedisListenerEndpoint(MessageListener messageListener)

Method Details

setMessageListener

public void setMessageListener(@Nullable MessageListener messageListener)

Set the MessageListener to invoke when a message matching the endpoint is received.

getMessageListener

public @Nullable MessageListener getMessageListener()

Return the MessageListener to invoke when a message matching the endpoint is received.

createListener

protected @Nullable MessageListener createListener()

Description copied from class: AbstractRedisListenerEndpoint

Create the MessageListener for this endpoint.

Specified by:

createListener in class AbstractRedisListenerEndpoint

getEndpointDescription

protected StringBuilder getEndpointDescription()

Description copied from class: AbstractRedisListenerEndpoint

Return a description for this endpoint.

Available to subclasses, for inclusion in their toString() result.

Overrides:

getEndpointDescription in class AbstractRedisListenerEndpoint