diff --git a/exo.core.component.organization.api/src/main/java/org/exoplatform/services/organization/externalstore/IDMExternalStoreImportService.java b/exo.core.component.organization.api/src/main/java/org/exoplatform/services/organization/externalstore/IDMExternalStoreImportService.java index 50fc7c7cf..51f3fdb89 100644 --- a/exo.core.component.organization.api/src/main/java/org/exoplatform/services/organization/externalstore/IDMExternalStoreImportService.java +++ b/exo.core.component.organization.api/src/main/java/org/exoplatform/services/organization/externalstore/IDMExternalStoreImportService.java @@ -1040,7 +1040,7 @@ private void initializeDataDeleteScheduledJob() throws Exception { } private void initializeQueueProcessingScheduledJob() throws Exception { - if (StringUtils.isBlank(scheduledDataImportJobCronExpression)) { + if (StringUtils.isBlank(scheduledQueueProcessingJobCronExpression)) { LOG.warn("Can't initialize Cron Job for IDM Queue Processing, the cron expression is empty"); return; } @@ -1050,7 +1050,7 @@ private void initializeQueueProcessingScheduledJob() throws Exception { properties.setProperty("jobName", "IDM.QUEUE"); properties.setProperty("groupName", "PORTAL.IDM"); properties.setProperty("job", IDMQueueProcessorJob.class.getName()); - properties.setProperty("expression", scheduledDataImportJobCronExpression); + properties.setProperty("expression", scheduledQueueProcessingJobCronExpression); params.addParam(properties); jobSchedulerService.addCronJob(new CronJob(params)); }