package com.xcong.excoin.common.listener;
|
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.data.redis.connection.RedisConnectionFactory;
|
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
|
|
/**
|
* @author wzy
|
* @date 2021-04-16
|
**/
|
@Configuration
|
@ConditionalOnProperty(prefix = "app", name = "newest-price-update-job", havingValue = "true")
|
public class RedisListenerConfig {
|
|
@Bean
|
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
|
|
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
|
container.setConnectionFactory(connectionFactory);
|
// container.addMessageListener(new RedisExpiredListener(), new PatternTopic("__keyevent@0__:expired"));
|
return container;
|
}
|
}
|
