MQ初始化异常逻辑优化

framework-redis/src/main/java/com/chelvc/framework/redis/config/RedisConfigurer.java

@@ -23,6 +23,7 @@ import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator
 import io.lettuce.core.event.EventBus;
 import io.lettuce.core.resource.ClientResources;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.springframework.aop.framework.AopProxyUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -54,6 +55,7 @@ import org.springframework.stereotype.Component;
  * @author Woody
  * @date 2024/1/30
  */
+@Slf4j
 @Component
 @EnableCaching
 @AutoConfigureAfter(RedisAutoConfiguration.class)
@@ -81,7 +83,11 @@ public class RedisConfigurer extends CachingConfigurerSupport implements Applica
         RedisMQListenerContainer<T> container = ApplicationContextHolder.register(
                 this.counter.incrementAndGet(), RedisMQListenerContainer.class, DefaultRedisMQListenerContainer::new
         );
-        container.initialize(type, listener, annotation);
+        try {
+            container.initialize(type, listener, annotation);
+        } catch (Exception e) {
+            log.error("RedisMQListenerContainer initialize failed", e);
+        }
     }
 
     @Override

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/config/RocketMQConfigurer.java

@@ -77,7 +77,11 @@ public class RocketMQConfigurer implements ApplicationRunner {
                     return multiple ? new MultipleRocketMQListenerContainer<>() :
                             new SingleRocketMQListenerContainer<>();
                 });
-        container.initialize(type, this.provider(), this.configuration(), listener, annotation);
+        try {
+            container.initialize(type, this.provider(), this.configuration(), listener, annotation);
+        } catch (Exception e) {
+            log.error("RocketMQListenerContainer initialize failed", e);
+        }
     }
 
     @Override