问AEM 6.3 :使用OSGi R6注释创建调度程序

EN

import org.osgi.service.metatype.annotations.AttributeDefinition;
import org.osgi.service.metatype.annotations.AttributeType;
import org.osgi.service.metatype.annotations.ObjectClassDefinition;

@ObjectClassDefinition(name = "Sling Scheduler Configuration", description = "This configuration is used to demonstrates a sling scheduler in action")
public @interface SchedulerConfiguration {

    @AttributeDefinition(
            name = "Scheduler name", 
            description = "Name of the scheduler", 
            type = AttributeType.STRING)
    public String name() default "Custom Sling Scheduler";

    @AttributeDefinition(
            name = "Enabled", 
            description = "Flag to enable/disable a scheduler", 
            type = AttributeType.STRING)
    public boolean enabled() default false;

    @AttributeDefinition(
            name = "Cron expression", 
            description = "Cron expression used by the scheduler", 
            type = AttributeType.STRING)
    public String cronExpression() default "0 * * * * ?";

    @AttributeDefinition(
            name = "Custom parameter", 
            description = "Custom parameter to showcase the usage of a sling scheduler", 
            type = AttributeType.STRING)
    public String customParameter();
}

import org.apache.sling.commons.scheduler.ScheduleOptions;
import org.apache.sling.commons.scheduler.Scheduler;
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;
import org.osgi.service.metatype.annotations.Designate;
import org.redquark.aem.learning.core.configurations.SchedulerConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


@Component(immediate = true, service = Runnable.class)
@Designate(ocd = SchedulerConfiguration.class)
public class CustomScheduler implements Runnable {

    // Logger
    private final Logger log = LoggerFactory.getLogger(this.getClass());

    // Custom parameter that is to be read from the configuration
    private String customParameter;

    // Id of the scheduler based on its name
    private int schedulerId;

    // Scheduler instance injected
    @Reference
    private Scheduler scheduler;

    /**
     * Activate method to initialize stuff
     * 
     * @param schedulerConfiguration
     */
    @Activate
    protected void activate(SchedulerConfiguration schedulerConfiguration) {
        schedulerId = schedulerConfiguration.name().hashCode();
        customParameter = schedulerConfiguration.customParameter();
    }

    /**
     * Modifies the scheduler id on modification
     * 
     * @param schedulerConfiguration
     */
    @Modified
    protected void modified(SchedulerConfiguration schedulerConfiguration) {
        // Removing scheduler
        removeScheduler();
        // Updating the scheduler id
        schedulerId = schedulerConfiguration.name().hashCode();
        // Again adding the scheduler
        addScheduler(schedulerConfiguration);
    }

    /**
     * This method deactivates the scheduler and removes it
     * 
     * @param schedulerConfiguration
     */
    @Deactivate
    protected void deactivate(SchedulerConfiguration schedulerConfiguration) {
        // Removing the scheduler
        removeScheduler();
    }

    /**
     * This method removes the scheduler
     */
    private void removeScheduler() {
        log.info("Removing scheduler: {}", schedulerId);
        // Unscheduling/removing the scheduler
        scheduler.unschedule(String.valueOf(schedulerId));
    }

    /**
     * This method adds the scheduler
     * 
     * @param schedulerConfiguration
     */
    private void addScheduler(SchedulerConfiguration schedulerConfiguration) {
        // Check if the scheduler is enabled
        if (schedulerConfiguration.enabled()) {
            // Scheduler option takes the cron expression as a parameter and run accordingly
            ScheduleOptions scheduleOptions = scheduler.EXPR(schedulerConfiguration.cronExpression());

            // Adding some parameters
            scheduleOptions.name(schedulerConfiguration.name());
            scheduleOptions.canRunConcurrently(false);

            // Scheduling the job
            scheduler.schedule(this, scheduleOptions);
            log.info("Scheduler added");
        } else {
            log.info("Scheduler is disabled");
        }
    }

    /**
     * Overridden run method to execute Job
     */
    @Override
    public void run() {
        log.info("Custom Scheduler is now running using the passed custom paratmeter, customParameter {}",
                customParameter);

    }

@Component(immediate = true, service=Runnable.class)
@Designate(ocd=SchedulerConfiguration.class)
public class WeatherServiceScheduler implements Runnable {