1. Home
  2. Development
  3. RE: scheduler module in liferay dxp 7.3

RE: scheduler module in liferay dxp 7.3

Jamie Sammons, modified 3 Years ago.
scheduler module in liferay dxp 7.3
New Member Posts: 7 Join Date: 10/21/21 Recent Posts

Hi ,

How can I create a scheduler module in liferay dxp 7.3 . Please share link to documentation or an example .

Can you create scheduler class with implements  SchedulerEngine ?  and then configure the cron expression?  

Please pour in your inputs. 

 

Regards,

Prathibha

Scarletake Bwi, modified 3 Years ago.
RE: scheduler module in liferay dxp 7.3
Expert Posts: 327 Join Date: 12/20/10 Recent Posts

i want to know it too.

in current, i use BaseMessageListener.

package com.raritan.ci.srg.scheduler;


@Component(immediate = true, property = { "cron.expression=*/5 * * * * ?" }, 
		service = RecordSyncScheduler.class)
public class RecordSyncScheduler extends BaseMessageListener {
	private static Log LOGGER = LogFactoryUtil.getLog(RecordSyncScheduler.class);
	@Override
	protected void doReceive(Message message) throws Exception {

}
	@Activate
	@Modified
	protected void activate(Map<String, Object> properties) throws SchedulerException {
		try {
			String cronExpression = GetterUtil.getString(properties.get("cron.expression"), "cronExpression");
			LOGGER.info(" cronExpression: " + cronExpression);

			String listenerClass = getClass().getName();
			Trigger jobTrigger = TriggerFactoryUtil.createTrigger(listenerClass, listenerClass, new Date(), null, cronExpression);

			SchedulerEntryImpl schedulerEntryImpl = new SchedulerEntryImpl(listenerClass, jobTrigger);
			SchedulerEngineHelperUtil.register(this, schedulerEntryImpl, DestinationNames.SCHEDULER_DISPATCH);

		} catch (Exception e) {
			LOGGER.error(e);
		}
	}

	@Deactivate
	protected void deactive() {
		SchedulerEngineHelperUtil.unregister(this);
	}
}

 

srini vasulu, modified 2 Years ago.
RE: RE: scheduler module in liferay dxp 7.3
Regular Member Posts: 139 Join Date: 2/22/11 Recent Posts

Hi,

In Liferay 7.4.3.30 i am implemented same way but still added scheduler details in database and it's not running the scheduler based on time scheduler.

Jamie Sammons, modified 11 Months ago.
RE: scheduler module in liferay dxp 7.3
New Member Posts: 24 Join Date: 6/13/23 Recent Posts

Hello, Refer below code:

import com.liferay.portal.kernel.log.Log;

import com.liferay.portal.kernel.log.LogFactoryUtil;

import com.liferay.portal.kernel.messaging.DestinationNames;

import com.liferay.portal.kernel.messaging.Message;

import com.liferay.portal.kernel.messaging.MessageListener;

import com.liferay.portal.kernel.messaging.MessageListenerException;

import com.liferay.portal.kernel.scheduler.SchedulerEngineHelper;

import com.liferay.portal.kernel.scheduler.SchedulerEntry;

import com.liferay.portal.kernel.scheduler.SchedulerEntryImpl;

import com.liferay.portal.kernel.scheduler.SchedulerException;

import com.liferay.portal.kernel.scheduler.Trigger;

import com.liferay.portal.kernel.scheduler.TriggerFactoryUtil;

import com.liferay.portal.kernel.util.GetterUtil;

import java.util.Date;

import java.util.Map;

import org.osgi.service.component.annotations.Activate;

import org.osgi.service.component.annotations.Component;

import org.osgi.service.component.annotations.Deactivate;

import org.osgi.service.component.annotations.Modified;

import org.osgi.service.component.annotations.Reference;

@Component(   immediate = true,

        property = {

            "cron.expression=0 0/1 * 1/1 * ? *" //Occurs every minute

             },

        service = EmailSchedulerPortlet.class    

)

public class EmailSchedulerPortlet implements MessageListener {

private final Log logger = LogFactoryUtil.getLog(EmailSchedulerPortlet.class);

@Reference

    SchedulerEngineHelper _helper;

@Activate

@Modified

    protected void activate(Map<String,Object> properties) throws SchedulerException {

    try {

    String cronExpression =  GetterUtil.getString(properties.get("cron.expression"), "cronExpression");

    logger.info(" cronExpression: " + cronExpression);

    String listenerClass = getClass().getName();

    Trigger jobTrigger = TriggerFactoryUtil.createTrigger(listenerClass, listenerClass, new Date(), null, cronExpression);

    SchedulerEntry entry = new SchedulerEntryImpl(listenerClass, jobTrigger);

      _helper.register(this, entry, DestinationNames.SCHEDULER_DISPATCH);

    } catch (Exception e) {

    logger.error(e);

    }

}

@Deactivate

    protected void deactive() {

    _helper.unregister(this);

}

@Override

    public void receive(Message arg0) throws MessageListenerException {

    logger.info("Hello every minute");

    //Your Business logic

    }

}