This is an automated email from the ASF dual-hosted git repository.

aleks pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/fineract.git


The following commit(s) were added to refs/heads/develop by this push:
     new 6f39c8ffe FINERACT-1682: Fix job key refresh logic for inactive 
schedulers
6f39c8ffe is described below

commit 6f39c8ffeddb9e1571289fed6d0e91dd0975fdf2
Author: Adam Saghy <[email protected]>
AuthorDate: Sun Aug 7 19:23:01 2022 +0200

    FINERACT-1682: Fix job key refresh logic for inactive schedulers
---
 .../infrastructure/jobs/service/JobRegisterServiceImpl.java | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/jobs/service/JobRegisterServiceImpl.java
 
b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/jobs/service/JobRegisterServiceImpl.java
index 3bd5b2fc2..fb9e1d8a1 100644
--- 
a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/jobs/service/JobRegisterServiceImpl.java
+++ 
b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/jobs/service/JobRegisterServiceImpl.java
@@ -230,17 +230,18 @@ public class JobRegisterServiceImpl implements 
JobRegisterService, ApplicationLi
 
     @Override
     public void scheduleJob(final ScheduledJobDetail scheduledJobDetails) {
-        if (!scheduledJobDetails.isActiveSchedular()) {
-            scheduledJobDetails.updateNextRunTime(null);
-            scheduledJobDetails.updateCurrentlyRunningStatus(false);
-            return;
-        }
         try {
             final JobDetail jobDetail = createJobDetail(scheduledJobDetails);
+            
scheduledJobDetails.updateJobKey(getJobKeyAsString(jobDetail.getKey()));
+            if (!scheduledJobDetails.isActiveSchedular()) {
+                scheduledJobDetails.updateNextRunTime(null);
+                scheduledJobDetails.updateCurrentlyRunningStatus(false);
+                return;
+            }
+
             final Trigger trigger = createTrigger(scheduledJobDetails, 
jobDetail);
             final Scheduler scheduler = getScheduler(scheduledJobDetails);
             scheduler.scheduleJob(jobDetail, trigger);
-            
scheduledJobDetails.updateJobKey(getJobKeyAsString(jobDetail.getKey()));
             scheduledJobDetails.updateNextRunTime(trigger.getNextFireTime());
             scheduledJobDetails.updateErrorLog(null);
         } catch (final Throwable throwable) {

Reply via email to