Add some logs

job-streamer · Apr 10, 2017 · 0c2c198 · 0c2c198
1 parent 3d1fc10
commit 0c2c198
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java b/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java
@@ -24,8 +24,11 @@ public void execute(JobExecutionContext context) throws JobExecutionException {
         JobDataMap data = context.getMergedJobDataMap();
         String jobName = data.getString("job-name");
         String appName = data.getString("app-name");
-        if (jobName == null || appName == null) return;
         logger.info("execute job that " + "jobName:" + jobName + " appName:" + appName + " execution-id:" + data.getString("execution-id") + " command:" + data.getString("command"));
+        if (jobName == null || appName == null) {
+          logger.warn("not execute invalid job. look back the setting");
+          return;
+        }
 
         Object system = SystemUtil.getSystem();
         Object jobs = RT.get(system, Keyword.intern("jobs"));