moved ping of scheduler

Author: sterlp

core/src/main/java/org/sterl/spring/persistent_tasks/scheduler/SchedulerService.java

@@ -129,16 +129,18 @@ public <T extends Serializable> Future<TriggerKey> runOrQueue(
 
             if (taskExecutor.getFreeThreads() > 0) {
                 trigger = triggerService.markTriggersAsRunning(trigger, name);
+                pingRegistry().addRunning(1);
             } else {
                 log.debug("Currently not enough free thread available {} of {} in use. Task {} queued.", 
                         taskExecutor.getFreeThreads(), taskExecutor.getMaxThreads(), trigger.getKey());
             }
             return trigger;
         });
-        Future<TriggerKey> result = CompletableFuture.completedFuture(runningTrigger.getKey());
+        Future<TriggerKey> result;
         if (runningTrigger.isRunning()) {
             result = taskExecutor.submit(runningTrigger);
-            pingRegistry();
+        } else {
+            result = CompletableFuture.completedFuture(runningTrigger.getKey());
         }
         return result;
     }

core/src/main/java/org/sterl/spring/persistent_tasks/scheduler/entity/SchedulerEntity.java

@@ -43,4 +43,9 @@ public SchedulerEntity(String name) {
         super();
         this.id = name;
     }
+
+    public SchedulerEntity addRunning(int count) {
+        this.runnungTasks += count;
+        return this;
+    }
 }