This commit is contained in:
weiyachao 2023-11-15 16:48:10 +08:00
parent 0144506748
commit f1c1bfdf94

View File

@ -1,6 +1,7 @@
package com.qiuguo.iot.admin.http.api.filter;
import com.qiuguo.iot.base.constans.Log4Constans;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.reactivestreams.Subscription;
import org.slf4j.MDC;
@ -37,6 +38,7 @@ public class LogMdcConfiguration {
Hooks.resetOnEachOperator(Log4Constans.PRINT_LOG_ID);
}
@Data
class MdcContextSubscriber<T> implements CoreSubscriber<T> {
private CoreSubscriber<T> coreSubscriber;
public MdcContextSubscriber(CoreSubscriber<T> c){