package org.sxkj.job.processor;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
import tech.powerjob.worker.core.processor.ProcessResult;
|
import tech.powerjob.worker.core.processor.TaskContext;
|
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
|
import tech.powerjob.worker.log.OmsLogger;
|
|
|
/**
|
* LogTestProcessor
|
*
|
* @author tjq
|
* @since 2022/9/18
|
*/
|
@Component
|
@Slf4j
|
public class LogTestProcessor implements BasicProcessor {
|
|
@Override
|
public ProcessResult process(TaskContext context) throws Exception {
|
final OmsLogger omsLogger = context.getOmsLogger();
|
log.info("任务信息：{}",context);
|
return new ProcessResult(true);
|
}
|
}
|
