Merge pull request #76 from seki-seki/fix/not-to-execute-invalid-job

insert null check
job-streamer · Apr 10, 2017 · 8bdc88b · 8bdc88b
2 parents 5235a90 + 0c2c198
commit 8bdc88b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java b/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java
@@ -25,6 +25,10 @@ public void execute(JobExecutionContext context) throws JobExecutionException {
         String jobName = data.getString("job-name");
         String appName = data.getString("app-name");
         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"));