redis配置类调整

esua-epdc/epdc-admin/epdc-admin-server/src/test/java/com/elink/esua/epdc/service/DynamicDataSourceTest.java

@@ -18,12 +18,14 @@
 package com.elink.esua.epdc.service;
 
 import com.elink.esua.epdc.commons.tools.exception.RenException;
+import com.elink.esua.epdc.commons.tools.redis.RedisChannels;
 import com.elink.esua.epdc.utils.WxMaServiceUtils;
 import me.chanjar.weixin.common.error.WxErrorException;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.test.context.junit4.SpringRunner;
 
 import java.io.File;
@@ -76,4 +78,13 @@ public class DynamicDataSourceTest {
 
     }
 
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
+
+    @Test
+    public void test3() {
+        String json = "{'postId':'666','carNum':'123'}";
+        redisTemplate.convertAndSend(RedisChannels.COMPLETE_INFO_BY_SENTRY_POST, json);
+    }
+
 }

esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/config/RedisMessageConfig.java

@@ -17,20 +17,23 @@ import org.springframework.stereotype.Component;
 @Component
 public class RedisMessageConfig {
 
+    @Autowired
+    private RedisConnectionFactory factory;
+
     @Autowired
     private SentryPostUserInfoRedisListener sentryPostUserInfoRedisListener;
 
     @Bean
-    MessageListenerAdapter SentryPostUserInfoAdapter() {
+    MessageListenerAdapter sentryPostUserInfoAdapter() {
         return new MessageListenerAdapter(sentryPostUserInfoRedisListener);
     }
 
+
     @Bean
-    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
-                                            MessageListenerAdapter SentryPostUserInfoAdapter) {
+    RedisMessageListenerContainer container() {
         RedisMessageListenerContainer container = new RedisMessageListenerContainer();
-        container.setConnectionFactory(connectionFactory);
-        container.addMessageListener(SentryPostUserInfoAdapter, new PatternTopic(RedisChannels.COMPLETE_INFO_BY_SENTRY_POST));
+        container.setConnectionFactory(factory);
+        container.addMessageListener(sentryPostUserInfoAdapter(), new PatternTopic(RedisChannels.COMPLETE_INFO_BY_SENTRY_POST));
         return container;
     }
 

esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/listener/SentryPostUserInfoRedisListener.java

@@ -12,7 +12,6 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.Message;
 import org.springframework.data.redis.connection.MessageListener;
-import org.springframework.lang.Nullable;
 import org.springframework.stereotype.Service;
 
 /**