File tree Expand file tree Collapse file tree 1 file changed +9
-6
lines changed
core/src/main/java/org/sterl/spring/persistent_tasks/scheduler Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -70,11 +70,14 @@ public void shutdownNow() {
7070 }
7171
7272 public SchedulerEntity pingRegistry () {
73- var result = editSchedulerStatus .checkinToRegistry (name );
74- result .setRunnungTasks (taskExecutor .getRunningTasks ());
75- result .setTasksSlotCount (taskExecutor .getMaxThreads ());
76- log .debug ("Ping {}" , result );
77- return result ;
73+ // using trx template to ensure the TRX is started if we use this method internally
74+ return trx .execute (t -> {
75+ var result = editSchedulerStatus .checkinToRegistry (name );
76+ result .setRunnungTasks (taskExecutor .getRunningTasks ());
77+ result .setTasksSlotCount (taskExecutor .getMaxThreads ());
78+ log .debug ("Ping {}" , result );
79+ return result ;
80+ });
7881 }
7982
8083 public SchedulerEntity getScheduler () {
@@ -108,7 +111,7 @@ public List<Future<TriggerKey>> triggerNextTasks(OffsetDateTime timeDue) {
108111 triggers = Collections .emptyList ();
109112 }
110113 var result = taskExecutor .submit (triggers );
111- trx . executeWithoutResult ( t -> this . pingRegistry () );
114+ pingRegistry ();
112115 return result ;
113116 }
114117
You can’t perform that action at this time.
0 commit comments