修改打印常量引起的错误
This commit is contained in:
parent
cb4661b681
commit
50ce682051
@ -107,10 +107,10 @@ public abstract class ActionCommand {
|
|||||||
|
|
||||||
protected Mono<Void> setQueueMessage(BaseSession baseSession, QueueMessage queue, Integer type){
|
protected Mono<Void> setQueueMessage(BaseSession baseSession, QueueMessage queue, Integer type){
|
||||||
return Mono.defer(() -> {
|
return Mono.defer(() -> {
|
||||||
MDC.put(LogMdcConfiguration.PRINT_LOG_ID, baseSession.getLogId());
|
MDC.put(Log4Constans.PRINT_LOG_ID, baseSession.getLogId());
|
||||||
StringBuilder sb = new StringBuilder();
|
StringBuilder sb = new StringBuilder();
|
||||||
return sendMessage(baseSession, queue, sb, type).flatMap(m -> {
|
return sendMessage(baseSession, queue, sb, type).flatMap(m -> {
|
||||||
MDC.remove(LogMdcConfiguration.PRINT_LOG_ID);
|
MDC.remove(Log4Constans.PRINT_LOG_ID);
|
||||||
return Mono.empty();
|
return Mono.empty();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user