微调
This commit is contained in:
@@ -61,4 +61,12 @@ public class RocketMQEnhanceAutoConfiguration {
|
|||||||
public EnvironmentIsolationConfig environmentSetup(RocketEnhanceProperties rocketEnhanceProperties){
|
public EnvironmentIsolationConfig environmentSetup(RocketEnhanceProperties rocketEnhanceProperties){
|
||||||
return new EnvironmentIsolationConfig(rocketEnhanceProperties);
|
return new EnvironmentIsolationConfig(rocketEnhanceProperties);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/***
|
||||||
|
* rocketmq日志输出
|
||||||
|
*/
|
||||||
|
@Bean
|
||||||
|
public RocketMQLogEnhance rocketMQLogEnhance(){
|
||||||
|
return new RocketMQLogEnhance();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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");
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user