diff --git a/powerjob-worker-samples/src/main/java/tech/powerjob/samples/processors/SimpleProcessor.java b/powerjob-worker-samples/src/main/java/tech/powerjob/samples/processors/SimpleProcessor.java index 96a8f382..b82b9cf8 100644 --- a/powerjob-worker-samples/src/main/java/tech/powerjob/samples/processors/SimpleProcessor.java +++ b/powerjob-worker-samples/src/main/java/tech/powerjob/samples/processors/SimpleProcessor.java @@ -13,7 +13,6 @@ import java.util.Optional; */ public class SimpleProcessor implements BasicProcessor { - @Override public ProcessResult process(TaskContext context) throws Exception { @@ -23,6 +22,11 @@ public class SimpleProcessor implements BasicProcessor { logger.info("Current context:{}", context.getWorkflowContext()); logger.info("Current job params:{}", jobParams); + // 测试中文问题 #581 + if (jobParams.contains("CN")) { + return new ProcessResult(true, "任务成功啦!!!"); + } + return jobParams.contains("F") ? new ProcessResult(false) : new ProcessResult(true, "yeah!"); } diff --git a/powerjob-worker-samples/src/main/resources/application.properties b/powerjob-worker-samples/src/main/resources/application.properties index db69a909..ceb6fda9 100644 --- a/powerjob-worker-samples/src/main/resources/application.properties +++ b/powerjob-worker-samples/src/main/resources/application.properties @@ -4,7 +4,7 @@ spring.jpa.open-in-view=false # Whether to enable PowerJob Worker, default is true powerjob.worker.enabled=true # Turn on test mode and do not force the server connection to be verified -powerjob.worker.enable-test-mode=true +powerjob.worker.enable-test-mode=false # Transport port, default is 27777 powerjob.worker.port=27777 # Application name, used for grouping applications. Recommend to set the same value as project name.