Don’t miss the AEM Skill Exchange in SF on Nov 14—hear from industry leaders, learn best practices, and enhance your AEM strategy with practical tips.
gatewaytimeout while creating package programatically in AEMasCS
Dear Developers/Architects,
I was trying to create packages programatically in AEM, it fetchs given page's path and page's reffrences like xf paths and dampaths(more than 1500 dampaths), i combined content path and xf path in seprate package(package-0). when comes to dampath i splited the dampath in to 300 dampath/package and tried to create packages(package-1,package-2 & viceversa..). when i ran this code in my local aem instance, i was able to create spilt of packages(combined (xf & content paths) package and split of dampath packages) without any issues. when i deploy the code on AEMasCS, im getting gateway timeout issue. Kindly let us know your suggestion on this...
java code if the dampath more than 300
Topics
Topics help categorize Community content and increase your ability to discover relevant content.
Please check the permission in user admin for that user.if not,apply the permission to the user which ever required.
Hi @yashp0808 ,thanks for your response, the gateway timeout issue happened on the line below higlighted in the screenshot attached, where createPackage method. so saving the session will not work in the finally block.
@Kamal_Kishor , the size of the package was not able to size on package manager wizard,as it was incomplete state.please find the screenshot.
@raja-thannasi Did you find the suggestions from users helpful? Please let us know if more information is required. Otherwise, please mark the answer as correct for posterity. If you have found out solution yourself, please share it with the community.
Kautuk Sahni
Hi @raja-thannasi
A good approach all we should have is a system user with required permissions. Here is the below code which achieves our requirement.
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.HashMap;
import java.util.Map;
import javax.jcr.RepositoryException;
import javax.jcr.Session;
import javax.servlet.Servlet;
import org.apache.jackrabbit.vault.fs.api.PathFilterSet;
import org.apache.jackrabbit.vault.fs.api.ProgressTrackerListener;
import org.apache.jackrabbit.vault.fs.config.DefaultWorkspaceFilter;
import org.apache.jackrabbit.vault.packaging.JcrPackage;
import org.apache.jackrabbit.vault.packaging.JcrPackageDefinition;
import org.apache.jackrabbit.vault.packaging.JcrPackageManager;
import org.apache.jackrabbit.vault.packaging.PackageException;
import org.apache.jackrabbit.vault.packaging.PackagingService;
import org.apache.jackrabbit.vault.util.DefaultProgressListener;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.SlingHttpServletResponse;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceResolverFactory;
import org.apache.sling.api.servlets.HttpConstants;
import org.apache.sling.api.servlets.SlingAllMethodsServlet;
import org.osgi.framework.Constants;
import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@Component(service = Servlet.class, property = {
Constants.SERVICE_DESCRIPTION + "= API to download packages based on path",
"sling.servlet.methods=" + HttpConstants.METHOD_GET, "sling.servlet.paths=" + "/bin/api/createpackage" })
public class PackagecreateServlet extends SlingAllMethodsServlet {
private static final long serialVersionUID = 1L;
private transient Logger log = LoggerFactory.getLogger(PackagecreateServlet.class);
@Reference
private transient ResourceResolverFactory resolverFactory;
private void closePackageStream(InputStream packageStream) {
if (packageStream != null) {
try {
packageStream.close();
} catch (IOException e) {
log.error("Error while closing InputStream", e);
}
}
}
private InputStream getPackageStream(JcrPackage pack) throws Exception {
if (pack != null && pack.getNode() != null && pack.getNode().hasProperty("jcr:content/jcr:data")) {
return pack.getNode().getProperty("jcr:content/jcr:data").getBinary().getStream();
}
return null;
}
@Override
protected void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response) throws IOException {
String packageName = request.getParameter("packageName");
String packagePath = request.getParameter("packagePath");
JcrPackageManager jpm = null;
if (packageName == null || packageName.isEmpty() || packagePath == null || packagePath.isEmpty()) {
response.getWriter().write("failed: URL parameters 'packageName' or 'packagePath' are missing");
return;
}
String[] paths = packagePath.replace("[", "").replace("]", "").split(",");
ResourceResolver resourceResolver = null;
Session session = null;
JcrPackage pack = null;
InputStream packageStream = null;
try {
Map<String, Object> param = new HashMap<>();
param.put(ResourceResolverFactory.SUBSERVICE, "subservice");
resourceResolver = resolverFactory.getServiceResourceResolver(param);
session = resourceResolver.adaptTo(Session.class);
jpm = PackagingService.getPackageManager(session);
pack = jpm.create("testPackage", packageName, "1.0.0");
JcrPackageDefinition definition = pack.getDefinition();
DefaultWorkspaceFilter filter = new DefaultWorkspaceFilter();
for (String path : paths) {
PathFilterSet pathFilterSet = new PathFilterSet();
pathFilterSet.setRoot(path.trim());
filter.add(pathFilterSet);
}
boolean autoSave = true;
if (definition != null)
definition.setFilter(filter, autoSave);
ProgressTrackerListener listener = new DefaultProgressListener();
jpm.assemble(pack, listener);
packageStream = getPackageStream(pack);
if (packageStream != null) {
response.setContentType("application/zip");
response.setHeader("Content-Disposition", "attachment; filename=test-dynamic-package-1.0.0.zip");
OutputStream out = response.getOutputStream();
byte[] buffer = new byte[4096];
int bytesRead;
while ((bytesRead = packageStream.read(buffer)) != -1) {
out.write(buffer, 0, bytesRead);
}
out.flush();
} else {
response.getWriter().write("failed: Package content is not available");
}
} catch (PackageException e) {
log.error("Package Exception: " + e.getMessage(), e);
response.getWriter().write("failed: PackageException - " + e.getMessage());
} catch (Exception e) {
log.error("Error while processing request", e);
response.getWriter().write("failed: " + e.getMessage());
} finally {
closePackageStream(packageStream);
if (pack != null) {
try {
jpm.remove(pack);
} catch (RepositoryException e) {
log.error("Package Exception: " + e.getMessage(), e);
}
}
if (resourceResolver != null && resourceResolver.isLive()) {
resourceResolver.close();
}
if (session != null && session.isLive()) {
session.logout();
}
}
}
}
URL how it looks like : http://localhost:portnumber/bin/api/createpackage?packageName=testpackage&packagePath=[/content/abcp... After hitting this URL in browser a package gets downloaded into your local. we can add 'n' number of filters in the array of URL and customize the logic as per our requirement version we used is AEM 6.5. If we comment this piece of code jpm.remove(pack); the package is visible in /crx/packmgr/index.jsp.
