|
|
@ -22,7 +22,7 @@ import org.springframework.data.redis.serializer.StringRedisSerializer; |
|
|
|
public class RedisConfig extends CachingConfigurerSupport { |
|
|
|
public class RedisConfig extends CachingConfigurerSupport { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Bean(destroyMethod = "destroy") |
|
|
|
/* @Bean(destroyMethod = "destroy") |
|
|
|
public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory factory, |
|
|
|
public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory factory, |
|
|
|
MessageListener driverLBSMsgListener) { |
|
|
|
MessageListener driverLBSMsgListener) { |
|
|
|
RedisMessageListenerContainer container = new RedisMessageListenerContainer(); |
|
|
|
RedisMessageListenerContainer container = new RedisMessageListenerContainer(); |
|
|
@ -32,7 +32,7 @@ public class RedisConfig extends CachingConfigurerSupport { |
|
|
|
container.addMessageListener(driverLBSMsgListener, new PatternTopic(MsgTopic.oilPriceTask.getName())); |
|
|
|
container.addMessageListener(driverLBSMsgListener, new PatternTopic(MsgTopic.oilPriceTask.getName())); |
|
|
|
|
|
|
|
|
|
|
|
return container; |
|
|
|
return container; |
|
|
|
} |
|
|
|
}*/ |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
|
* retemplate相关配置 |
|
|
|
* retemplate相关配置 |
|
|
|