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); } }