I am using below code to dynamically assign an ID to a component/template. Seems this is not getting triggered. Please help
import javax.jcr.Node;
import javax.jcr.RepositoryException;
import javax.jcr.Session;
import javax.jcr.observation.Event;
import javax.jcr.observation.EventListener;
import javax.jcr.observation.ObservationManager;
import javax.jcr.observation.EventIterator;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceResolverFactory;
import org.apache.sling.jcr.api.SlingRepository;
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.Reference;
import org.osgi.framework.BundleContext;
import org.osgi.service.component.ComponentContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
@Component(
immediate=true,
service= EventListener.class
)
public class UniqueIDListener implements EventListener {
private Logger log = LoggerFactory.getLogger(this.getClass());
private BundleContext bundleContext;
@Reference
private SlingRepository repository;
//Inject a Sling ResourceResolverFactory
@Reference
private ResourceResolverFactory resolverFactory;
private Session session;
private ObservationManager observationManager;
public void run() {
log.info("Unique ID Process Running..");
}
@Activate
public void activate(ComponentContext context) throws Exception {
this.bundleContext = context.getBundleContext();
log.info("Activating Unique ID");
try {
//Invoke adaptTo method to create a Session
Map<String, Object> param = new HashMap<String, Object>();
param.put(ResourceResolverFactory.SUBSERVICE, "datawrite");
ResourceResolver resolver = resolverFactory.getServiceResourceResolver(param);
Session session = resolver.adaptTo(Session.class);
//Setup the event handler to respond to a new node under /content/experience-fragments/aem
observationManager = session.getWorkspace().getObservationManager();
// final String[] nodetypes = {"cq:Page"};
final String path = "/content/experience-fragments/ahm/language_masters/english/widgets"; //define path
observationManager.addEventListener(this, Event.NODE_ADDED, path, true, null, null, false);
} catch (Exception e) {
log.error("Unable to register session", e);
throw new Exception(e);
}
}
@Deactivate
public void deactivate(ComponentContext componentContext) throws RepositoryException {
if (observationManager != null) {
observationManager.removeEventListener(this);
}
if (session != null) {
session.logout();
session = null;
}
}
//Defines logic that is fired when the event occurs
public void onEvent(EventIterator itr) {
UUID id = UUID.randomUUID();
try {
while (itr.hasNext()) {
Event newEvent = itr.nextEvent();
//log the time when the event occurred
log.info("A new node was added.. : {}", newEvent.getPath());
//Check if node exists and it is a content node of the newly created page
if (session.nodeExists(newEvent.getPath()) && session.getNode(newEvent.getPath()).getProperty("jcr:primaryType").getString().equals("cq:PageContent")) {
Node contentNode = session.getNode(newEvent.getPath());
if (contentNode.getProperty("resourceID") != null) {
contentNode.setProperty("resourceID", id.toString());
}
}
} session.save();
} catch(Exception e){
log.error("Error while treating page creation events",e);
}
}
}
