public class KeyExpirationEventMessageListener extends KeyspaceEventMessageListener implements ApplicationEventPublisherAware
MessageListener
publishing RedisKeyExpiredEvent
s via ApplicationEventPublisher
by listening
to Redis keyspace notifications for key expirations.Constructor and Description |
---|
KeyExpirationEventMessageListener(RedisMessageListenerContainer listenerContainer)
Creates new
MessageListener for __keyevent@*__:expired messages. |
Modifier and Type | Method and Description |
---|---|
protected void |
doHandleMessage(Message message)
Handle the actual message
|
protected void |
doRegister(RedisMessageListenerContainer listenerContainer)
Register instance within the container.
|
protected void |
publishEvent(RedisKeyExpiredEvent event)
Publish the event in case an
ApplicationEventPublisher is set. |
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
afterPropertiesSet, destroy, init, onMessage, setKeyspaceNotificationsConfigParameter
public KeyExpirationEventMessageListener(RedisMessageListenerContainer listenerContainer)
MessageListener
for __keyevent@*__:expired
messages.listenerContainer
- must not be null.protected void doRegister(RedisMessageListenerContainer listenerContainer)
KeyspaceEventMessageListener
doRegister
in class KeyspaceEventMessageListener
listenerContainer
- never null.protected void doHandleMessage(Message message)
KeyspaceEventMessageListener
doHandleMessage
in class KeyspaceEventMessageListener
message
- never null.protected void publishEvent(RedisKeyExpiredEvent event)
ApplicationEventPublisher
is set.event
- can be null.public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface ApplicationEventPublisherAware
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.