diff --git a/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQEnhanceAutoConfiguration.java b/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQEnhanceAutoConfiguration.java index 79dcfba..bcf5ff8 100644 --- a/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQEnhanceAutoConfiguration.java +++ b/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQEnhanceAutoConfiguration.java @@ -61,4 +61,12 @@ public class RocketMQEnhanceAutoConfiguration { public EnvironmentIsolationConfig environmentSetup(RocketEnhanceProperties rocketEnhanceProperties){ return new EnvironmentIsolationConfig(rocketEnhanceProperties); } + + /*** + * rocketmq日志输出 + */ + @Bean + public RocketMQLogEnhance rocketMQLogEnhance(){ + return new RocketMQLogEnhance(); + } } diff --git a/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java b/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java new file mode 100644 index 0000000..dd46e08 --- /dev/null +++ b/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java @@ -0,0 +1,17 @@ +package com.njcn.middle.rocket.autoconfig; + +import org.springframework.beans.factory.InitializingBean; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年08月10日 10:38 + */ +public class RocketMQLogEnhance implements InitializingBean { + + @Override + public void afterPropertiesSet() throws Exception { + System.out.println("配置rocket日志"); + System.setProperty("rocketmq.client.logUseSlf4j", "true"); + } +} \ No newline at end of file