Level 2

Solved

Replicator is null

Forum|Forum|2 years ago
February 6, 2024
3 replies
1600 views

Hi

I am trying to create a servlet in AEM to unplish some pages. The servlet keeps throwing the nullpointer at:

replicator.replicate(session, ReplicationActionType.DEACTIVE, path);

I found the root cause is the replictor is null, here's how I set it:

@3214626
Replicator replicator;

I tried to do maven install and restarted the server multiple times but still not working, please advise.

Thank you

This post is no longer active and is closed to new replies. Need help? Start a new post to ask your question.

Best answer by SureshDhulipudi

can you change Reference also to OSGi instead of Apache

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

SureshDhulipudi

Community Advisor

can you paste complete service class code here:

== example ==

import com.day.cq.replication.Replicator;
import com.day.cq.replication.ReplicationActionType;
import com.day.cq.replication.ReplicationException;
import com.day.cq.wcm.api.Page;
import com.day.cq.wcm.api.PageManager;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceResolverFactory;
import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;

import javax.jcr.Session;

@8220494(service = MyPageDeactivationService.class)
public class MyPageDeactivationService {

@3214626
private Replicator replicator;

@3214626
private ResourceResolverFactory resolverFactory;

public void deactivatePage(String path) {
try {
ResourceResolver resolver = resolverFactory.getServiceResourceResolver(null);
PageManager pageManager = resolver.adaptTo(PageManager.class);
Page page = pageManager.getPage(path);

if (page != null) {
Session session = resolver.adaptTo(Session.class);
replicator.replicate(session, ReplicationActionType.DEACTIVATE, path);
}
} catch (Exception e) {
// handle exception
}
}
}

H

HanLAuthor

Level 2

Sure, Here's the code

import org.apache.sling.api.servlets.SlingAllMethodsServlet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Date;

import javax.jcr.Session;
import javax.jcr.query.Query;
import javax.jcr.query.QueryManager;
import javax.jcr.query.QueryResult;
import javax.jcr.query.RowIterator;
import javax.servlet.Servlet;

import org.osgi.service.component.annotations.Component;
import org.apache.felix.scr.annotations.Reference;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.SlingHttpServletResponse;
import org.apache.sling.api.resource.Resource;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ValueMap;

import com.day.cq.replication.ReplicationActionType;
import com.day.cq.replication.Replicator;


/**
*this class is used to unpublish page 
*/
@Component(service = Servlet.class,
property = {
"sling.servlet.methods=" + "GET",
"sling.servlet.paths =" + "/bin/test/UnpublishPage"})
public class UnpublishPageService extends SlingAllMethodsServlet {
	
	@Reference
	Replicator replicator;
	
	private static final long serialVersionUID = -6581930898331858088L;

    private final Logger log = LoggerFactory.getLogger(this.getClass());
    
    @9944223
    protected void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response) {
		try {
			  String queryString = "SELECT [jcr:path] FROM [cq:Page] AS s WHERE ISDESCENDANTNODE([/content/test])";


	            ResourceResolver resourceResolver = request.getResourceResolver();
	            
	            Session session = resourceResolver.adaptTo(Session.class);

	            QueryManager queryManager = session.getWorkspace().getQueryManager();

	            Query query = queryManager.createQuery(queryString, Query.JCR_SQL2);

	            QueryResult queryResult = query.execute();
	            	            
	            RowIterator rowIterator = queryResult.getRows();	           

	            while(rowIterator.hasNext()) {
	            	
	            	String path = rowIterator.nextRow().getPath();
	            	
	                Resource jcrContent = resourceResolver.getResource(path + "/jcr:content");
	                
	                Boolean autoUnpublishAtExpiry= false;	              
	                
	                ValueMap properties = jcrContent.getValueMap();
	                
	                autoUnpublishAtExpiry = properties.get("autoUnpublishAtExpiry", Boolean.class);
	                
	                Date expiryDate = properties.get("expiry", Date.class);
	                
	                Date currentDate = new Date();
	                
	            	if(autoUnpublishAtExpiry != null && autoUnpublishAtExpiry) {
	            		if(expiryDate !=null && currentDate.after(expiryDate)) {
		            		replicator.replicate(session, ReplicationActionType.DEACTIVATE, path); 
	            		}
	            	}
	            }
	            
	            session.save();
	            response.getWriter().write("Expired Page unpublished successfully");
			
		}catch(Exception e){
            log.error(e.getMessage(), e);
		}
	}
	

}

SureshDhulipudi

Accepted solution

Community Advisor

can you change Reference also to OSGi instead of Apache

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

SureshDhulipudi

Community Advisor

Check your bundle is up and running and also validate this service

Dipti_Chauhan

Community Advisor

Please check if your service is up and running. Otherwise I don't see any issue with the code snippet you shared.

Sharing working example which is also using osgi annotation :

import org.apache.sling.api.SlingHttpServletRequest; 
import org.apache.sling.api.SlingHttpServletResponse;
 import org.apache.sling.api.servlets.SlingAllMethodsServlet;
 import org.osgi.service.component.annotations.Component;
 import org.osgi.service.component.annotations.Reference; 
 import com.day.cq.replication.ReplicationActionType; 
 import com.day.cq.replication.Replicator; 
 @8220494(service = SlingAllMethodsServlet.class, property = { "sling.servlet.methods=POST", "sling.servlet.paths=/bin/publishPage" })
 public class PublishPageServlet extends SlingAllMethodsServlet
 { 
 @3214626
 private Replicator replicator;
 @9944223
 protected void doPost(SlingHttpServletRequest request, SlingHttpServletResponse response) throws Exception
 { String path = request.getParameter("path"); // Get the path of the page to publish 
 if (path != null) 
 { 
replicator.replicate(request.getResourceResolver().adaptTo(javax.jcr.Session.class), ReplicationActionType.ACTIVATE, path);
 response.getWriter().write("Page published successfully"); 
 } else { 
 response.setStatus(400); 
 response.getWriter().write("Missing 'path' parameter"); } } }

Sign up

Login with SSO

Login to the community

Login with SSO

Scanning file for viruses.

This file cannot be downloaded