@@ -14,8 +14,8 @@ public abstract class Consumer<T> extends Thread{
}
@Override
public void run() {
- logger.info("*******************Consumer:"+Thread.currentThread().getId()+" start");
ThreadContext.put("TRACE_ID", traceId);
+ logger.info("*******************Consumer:"+Thread.currentThread().getId()+" start");
try {
while (true) {
//先判断是否有异常结束