If you have configured the crons appropriately then it should execute all the jobs unless there is any error which is preventing the job to start.
However, i would suggest to implement your jobs using: https://dev.alfresco.com/resource/docs/java/org/alfresco/schedule/AbstractScheduledLockedJob.html
This implementation is cluster aware, so if your application is running in cluster, you won't face conflicts.
The link you shared is talking about this Abstract class as well. Check this section : "AbstractScheduledLockedJob (Cluster Aware Job Scheduler Implementation)"
Your job processor would look something like this:
package com.abhinav.jobs;
import org.alfresco.repo.security.authentication.AuthenticationUtil;
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
import org.alfresco.schedule.AbstractScheduledLockedJob;
import org.alfresco.service.transaction.TransactionService;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class CustomClusterAwareJobProcessor extends AbstractScheduledLockedJob {
private static final Log LOG = LogFactory.getLog(CustomClusterAwareJobProcessor.class);
private TransactionService transactionService;
@Override
public void executeJob(final JobExecutionContext jobCtx)
throws JobExecutionException {
LOG.info("CustomClusterAwareJobProcessor started...");
try {
// Run as system user since this job is user independent hence
// permission is required on repository
AuthenticationUtil.setRunAsUserSystem();
final RetryingTransactionCallback<Object> txnWork = new RetryingTransactionCallback<Object>() {
public Object execute() throws Exception {
//TODO:: YOUR CUSTOM CODE
}
};
transactionService.getRetryingTransactionHelper().doInTransaction(txnWork);
LOG.info("CustomClusterAwareJobProcessor finished.");
} catch (Exception excp) {
LOG.error("Exception occurred while processing job", excp);
}
}
public void setTransactionService(final TransactionService transactionService) {
this.transactionService = transactionService;
}
}
Update the context something like:
<bean id="customClusterAwareJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">
<property name="jobClass">
<value>com.abhinav.jobs.CustomClusterAwareJobProcessor</value>
</property>
<!--In the map, you can pass all the services you would need during the job processing-->
<property name="jobDataAsMap">
<map>
<entry key="transactionService">
<ref bean="transactionService"/>
</entry>
<!-- JobLockService used to aquire the lock on jobs while they are
being processed to avoid other thread to modify the jobs state-->
<entry key="jobLockService">
<ref bean="jobLockService"/>
</entry>
</map>
</property>
</bean>
<bean id="customClusterAwareJobTrigger" class="org.alfresco.util.CronTriggerBean">
<property name="jobDetail">
<ref bean="customClusterAwareJobDetail" />
</property>
<property name="scheduler">
<ref bean="schedulerFactory" />
</property>
<property name="cronExpression">
<!-- Provided the cron expession in alfresco-global.propeties file -->
<value>${customjob.cron.expression}</value>
</property>
</bean>
In alfresco-global.properties:
#This expression will execute the job every 1 minute
customjob.cron.expression=0 0/1 * 1/1 * ? *
You can configure the cron as per your requirement.
~Abhinav
(ACSCE, AWS SAA, Azure Admin)
