cleanup

Author: sterlp

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

@@ -126,14 +126,15 @@ public List<Future<TriggerKey>> triggerNextTasks(OffsetDateTime timeDue) {
             final var result = trx.execute(t -> {
                 var triggers = triggerService.lockNextTrigger(name, taskExecutor.getFreeThreads(), timeDue);
                 editSchedulerStatus.checkinToRegistry(name, 
-                        taskExecutor.countRunning() + triggers.size(), taskExecutor.getMaxThreads());
+                        taskExecutor.countRunning() + triggers.size(), 
+                        taskExecutor.getMaxThreads());
                 return triggers;
             });
 
             return taskExecutor.submit(result);
         } else {
-            log.info("No free threads {}/{} right now to run jobs due for: {}",
-                    taskExecutor.getFreeThreads(),
+            log.info("No free threads {}/{} right now to run jobs due={}",
+                    taskExecutor.countRunning(),
                     taskExecutor.getMaxThreads(),
                     timeDue);
             editSchedulerStatus.checkinToRegistry(name, taskExecutor.countRunning(), taskExecutor.getMaxThreads());

core/src/main/java/org/sterl/spring/persistent_tasks/scheduler/component/TaskExecutorComponent.java

@@ -143,7 +143,7 @@ public void shutdown() {
                         shutdownNow();
                     }
                 } else {
-                    log.info("Shutdown {} with.", schedulerName);
+                    log.info("Shutdown {}.", schedulerName);
                 }
             } finally {
                 executor = null;
@@ -210,7 +210,7 @@ public void setMaxThreads(int value) {
     }
 
     public int getMaxThreads() {
-        return isStopped() ? 0 : this.maxThreads.get();
+        return this.maxThreads.get();
     }
 
     public boolean isRunning(TriggerEntity trigger) {

core/src/main/java/org/sterl/spring/persistent_tasks/trigger/model/RunTaskWithStateCommand.java

@@ -43,7 +43,7 @@ public Optional<TriggerEntity> execute(EditTriggerComponent editTrigger) {
 
     private Optional<TriggerEntity> runTask(EditTriggerComponent editTrigger) {
         editTrigger.triggerIsNowRunning(trigger, state);
-        
+
         task.accept(state);
 
         var result = editTrigger.completeTaskWithSuccess(trigger.getKey(), state);

core/src/main/java/org/sterl/spring/persistent_tasks/trigger/model/TriggerEntity.java

@@ -73,11 +73,11 @@ public TriggerEntity cancel(Exception e) {
         if (e == null) {
             this.data.setExceptionName("PersistentTask canceled");
         } else {
-            data.setExceptionName(e.getClass().getName());
-            data.setLastException(ExceptionUtils.getStackTrace(e));
+            this.data.setExceptionName(e.getClass().getName());
+            this.data.setLastException(ExceptionUtils.getStackTrace(e));
         }
 
-        data.updateRunningDuration();
+        this.data.updateRunningDuration();
         return this;
     }