Add logging to `TransportInfoServiceImpl` and handle Redis publish exceptions

shaofan
1 parent bf132471
Showing 1 changed file with 8 additions and 1 deletions
sl-express-ms-transport-info-service/src/main/java/com/sl/transport/info/service/impl/TransportInfoServiceImpl.java
@@ -7,6 +7,7 @@ import com.sl.transport.info.config.RedisConfig;
 import com.sl.transport.info.entity.TransportInfoDetail;
 import com.sl.transport.info.entity.TransportInfoEntity;
 import com.sl.transport.info.service.TransportInfoService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.annotation.CachePut;
 import org.springframework.cache.annotation.Cacheable;
@@ -17,12 +18,14 @@ import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 @Service
+@Slf4j
 public class TransportInfoServiceImpl implements TransportInfoService {
     @Autowired
     private MongoTemplate mongoTemplate;
     @Autowired
     private Cache transportInfoCache;
+    @Autowired
     private StringRedisTemplate stringRedisTemplate;
     @Autowired
     private BloomFilterServiceImpl bloomFilterService;
@@ -59,7 +62,11 @@ public class TransportInfoServiceImpl implements TransportInfoService {
 //        清除缓存中的数据
 //        transportInfoCache.invalidate(transportOrderId);
-        stringRedisTemplate.convertAndSend(RedisConfig.CHANNEL_TOPIC, transportOrderId);
+        try {
+            stringRedisTemplate.convertAndSend(RedisConfig.CHANNEL_TOPIC, transportOrderId);
+        } catch (Exception e) {
+            log.error("失败", e);
+        }
         return mongoTemplate.save(transportInfoEntity);
     }