CopyPasteEventHandlerJob.java

package com.aemks.core.jobs;

import org.apache.sling.event.jobs.Job;
import org.apache.sling.event.jobs.consumer.JobConsumer;
import org.osgi.service.component.annotations.Component;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Component(
        service = JobConsumer.class,
        immediate = true,
        property = { JobConsumer.PROPERTY_TOPICS + "=com/aemks/core/jobs/handleCopyPasteEvent" })
public class CopyPasteEventHandlerJob implements JobConsumer {

    private final Logger logger = LoggerFactory.getLogger(getClass());

    @Override public JobResult process(Job job) {
        String eventPath = job.getProperty("eventPath", String.class);
        logger.info("Handling event for path {}",eventPath);
        /*
         * Do all your processing or handling here
         * (Eg: removing the synced metadata like reference ID or Offer ID)
         */
        return JobResult.OK;
    }
}