|
@@ -25,6 +25,7 @@ public class DistributionJob implements Job {
|
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
|
public void execute(JobExecutionContext context) throws JobExecutionException {
|
|
String traceId = ThreadLocalUtil.next();
|
|
String traceId = ThreadLocalUtil.next();
|
|
ThreadContext.put("TRACE_ID", traceId);
|
|
ThreadContext.put("TRACE_ID", traceId);
|
|
|
|
+ ThreadContext.put("CALLER", "TASK");
|
|
ScheduleJob scheduleJob = null;
|
|
ScheduleJob scheduleJob = null;
|
|
try {
|
|
try {
|
|
scheduleJob = (ScheduleJob) context.getMergedJobDataMap().get("scheduleJob");
|
|
scheduleJob = (ScheduleJob) context.getMergedJobDataMap().get("scheduleJob");
|