Replication Api

adobe/skills/plugins/aem/6.5-lts/skills/aem-replication/replication-api

作者 adobe940b8795c0dfApache-2.0197 個星標收錄於 2026年10月9日更新於 2026年10月8日儲存庫今天更新

Use the AEM 6.5 LTS Replication API for programmatic content activation, deactivation, and replication status management

僅含說明Software Development
AI 產生的概覽

指導開發者使用 AEM 6.5 LTS 複寫 API，以程式化方式啟用、停用內容並查詢複寫狀態。

功能
此技能說明 Adobe Experience Manager 6.5 LTS 複寫 API，涵蓋 Replicator 介面、ReplicationActionType、ReplicationOptions 與 ReplicationStatus。它列出方法簽章、參數、例外，以及單一路徑、多路徑、權限檢查與狀態查詢的 Java 程式碼範例。它也說明 Maven uber-jar 相依性，以及同步與非同步複寫的效能影響。
適用情境
適用於撰寫以程式化方式發佈或取消發佈內容的自訂 AEM 程式碼、在 OSGi 服務或 Servlet 中建置複寫工作流程、將複寫與外部系統整合，或在應用邏輯中讀取複寫狀態。
執行需求
需要已設定複寫代理的 AEM 6.5 LTS 環境、Java 開發環境、包含 AEM uber-jar 相依性的 Maven 專案，以及具備複寫權限的服務使用者或工作階段。此技能不附帶指令碼，僅提供指引與程式碼範例。

AEM 6.5 LTS Replication API

This skill provides comprehensive guidance on using the official Adobe Experience Manager 6.5 LTS Replication API for programmatic replication operations. The API enables custom code to activate, deactivate, and manage content distribution workflows.

When to Use This Skill

Use this skill when you need to:

  • Programmatically activate/deactivate content from custom code
  • Build custom replication workflows in OSGi services or servlets
  • Integrate replication with external systems
  • Implement custom replication triggers and automation
  • Check replication status in application logic
  • Create custom content distribution tools
  • Bulk replicate content via scripts
  • Implement conditional replication logic

Prerequisites

  • AEM 6.5 LTS environment with configured replication agents
  • Java development environment for AEM
  • Maven project with AEM dependencies
  • Understanding of OSGi services and Sling ResourceResolver
  • Configured replication agents (see configure-replication-agent skill)
  • Service user or user session with replication permissions

Official API Documentation

All public replication APIs are documented in the official Adobe AEM 6.5 LTS JavaDoc:

Core API Components

1. Replicator Interface

The primary service for managing replication operations.

Service Type: OSGi Service
Package: com.day.cq.replication
Interface: com.day.cq.replication.Replicator

2. ReplicationActionType Enum

Defines the type of replication operation:

TypePurposeEffect
ACTIVATEPublish contentSends to Publish instances
DEACTIVATEUnpublish contentRemoves from Publish
DELETEDelete from PublishPermanent removal
TESTTest replicationVerifies connectivity
REVERSEReverse replicatePublish → Author
INTERNAL_POLLInternal pollingSystem use

3. ReplicationOptions Class

Encapsulates optional parameters for replication requests.

4. ReplicationStatus Interface

Provides status information about replicated content.

Maven Dependencies

The Replication API is provided by the AEM uber-jar. Add to your pom.xml:

xml
<dependency>    <groupId>com.adobe.aem</groupId>    <artifactId>uber-jar</artifactId>    <classifier>apis</classifier>    <scope>provided</scope></dependency>

The uber-jar version should match your AEM 6.5 LTS installation. The Replication API (com.day.cq.replication.*) is included in the uber-jar and available at runtime.

Replicator Interface Methods

Method 1: replicate(Session, ReplicationActionType, String)

Signature:

java
void replicate(Session session,                ReplicationActionType type,                String path) throws ReplicationException

Parameters:

  • session - JCR session (user permissions determine access)
  • type - ReplicationActionType (ACTIVATE, DEACTIVATE, DELETE, etc.)
  • path - Content path to replicate (e.g., "/content/mysite/en/page")

Throws: ReplicationException if replication fails

Description: Triggers replication for a single path with default options.

Example:

java
import com.day.cq.replication.Replicator;import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import org.apache.sling.api.resource.ResourceResolver;import org.osgi.service.component.annotations.Reference;
import javax.jcr.Session;
@Referenceprivate Replicator replicator;
public void activatePage(ResourceResolver resolver, String pagePath)     throws ReplicationException {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath);}

Method 2: replicate(Session, ReplicationActionType, String, ReplicationOptions)

Signature:

java
void replicate(Session session,                ReplicationActionType type,                String path,               ReplicationOptions options) throws ReplicationException

Parameters:

  • session - JCR session
  • type - ReplicationActionType
  • path - Content path
  • options - ReplicationOptions for custom configuration

Description: Initiates replication with customizable options for one path.

Example:

java
import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import com.day.cq.replication.ReplicationOptions;import org.apache.sling.api.resource.ResourceResolver;
import javax.jcr.Session;
public void activatePageSync(ResourceResolver resolver, String pagePath)     throws ReplicationException {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }        ReplicationOptions opts = new ReplicationOptions();    opts.setSynchronous(true); // Wait for completion    opts.setSuppressVersions(true); // Don't create versions        replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath, opts);}

Method 3: replicate(Session, ReplicationActionType, String[], ReplicationOptions)

Signature:

java
void replicate(Session session,                ReplicationActionType type,                String[] paths,               ReplicationOptions options) throws ReplicationException

Parameters:

  • session - JCR session
  • type - ReplicationActionType
  • paths - Array of content paths (String[])
  • options - ReplicationOptions

Description: Handles replication across multiple paths with supplied settings.

Example:

java
import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import com.day.cq.replication.ReplicationOptions;import org.apache.sling.api.resource.ResourceResolver;
import javax.jcr.Session;
public void activateMultiplePages(ResourceResolver resolver, String[] pagePaths)     throws ReplicationException {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }        ReplicationOptions opts = new ReplicationOptions();    opts.setSynchronous(false); // Async for better performance        replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePaths, opts);}

Method 4: checkPermission(Session, ReplicationActionType, String)

Signature:

java
void checkPermission(Session session,                      ReplicationActionType type,                      String path) throws ReplicationException

Parameters:

  • session - JCR session
  • type - ReplicationActionType
  • path - Content path

Throws: ReplicationException if user lacks permissions

Description: Verifies whether a user has sufficient permissions for replication activities.

Example:

java
import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import org.apache.sling.api.resource.ResourceResolver;
import javax.jcr.Session;
public boolean canUserActivate(ResourceResolver resolver, String pagePath) {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    try {        replicator.checkPermission(session, ReplicationActionType.ACTIVATE, pagePath);        return true; // User has permission    } catch (ReplicationException e) {        return false; // User lacks permission    }}

Method 5: getReplicationStatus(Session, String)

Signature:

java
ReplicationStatus getReplicationStatus(Session session, String path)

Parameters:

  • session - JCR session
  • path - Content path

Returns: ReplicationStatus object or null if unavailable

Description: Retrieves the replication status for a given path.

Example:

java
import com.day.cq.replication.ReplicationStatus;import org.apache.sling.api.resource.ResourceResolver;
import javax.jcr.Session;import java.util.Calendar;
public ReplicationInfo getPageReplicationInfo(ResourceResolver resolver, String pagePath) {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    ReplicationStatus status = replicator.getReplicationStatus(session, pagePath);        if (status != null) {        boolean isActivated = status.isActivated();        Calendar lastPublished = status.getLastPublished();        String lastPublishedBy = status.getLastPublishedBy();                return new ReplicationInfo(isActivated, lastPublished, lastPublishedBy);    }    return null;}

Method 6: getActivatedPaths(Session, String)

Signature:

java
Iterator<String> getActivatedPaths(Session session, String path) throws ReplicationException

Parameters:

  • session - JCR session
  • path - Root path for subtree

Returns: Iterator of activated paths

Throws: ReplicationException

Description: Returns paths of all activated nodes for the given subtree path.

Example:

java
import com.day.cq.replication.ReplicationException;import org.apache.sling.api.resource.ResourceResolver;
import javax.jcr.Session;import java.util.ArrayList;import java.util.Iterator;import java.util.List;
public List<String> getActivatedPages(ResourceResolver resolver, String rootPath)     throws ReplicationException {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    Iterator<String> activatedPaths = replicator.getActivatedPaths(session, rootPath);        List<String> result = new ArrayList<>();    while (activatedPaths.hasNext()) {        result.add(activatedPaths.next());    }    return result;}

ReplicationOptions Class

Encapsulates optional configuration parameters for replication requests.

Official Documentation: ReplicationOptions JavaDoc

Key Methods:

setSynchronous(boolean)

Description: Controls whether replication executes synchronously (blocking) or asynchronously (default).

Parameters:

  • synchronous - true for synchronous, false for asynchronous (default)

Example:

java
ReplicationOptions opts = new ReplicationOptions();opts.setSynchronous(true); // Wait for replication to complete

Use cases:

  • Synchronous: When you need confirmation before proceeding (e.g., before redirecting user)
  • Asynchronous: Better performance for bulk operations

Thread-Blocking Implications:

When setSynchronous(true) is used, the calling thread blocks until replication completes across all target agents. This has important implications:

  • UI Performance: In servlets or sling models rendering pages, synchronous replication blocks the HTTP request thread. For large content or slow networks, this can cause noticeable page load delays or request timeouts.
  • Thread Pool Exhaustion: High-traffic scenarios with synchronous replication can exhaust the servlet container's request thread pool, causing cascading failures.
  • Recommended Pattern: Use asynchronous replication (false, the default) for user-facing operations. Reserve synchronous mode for background jobs, workflow steps, or cases where immediate confirmation is critical for correctness (e.g., transactional workflows).

Performance Comparison:

  • Asynchronous: Request returns immediately after queueing (~10-50ms)
  • Synchronous: Request waits for full replication cycle (500ms-5s typical, longer for large assets or network delays)
setFilter(AgentFilter)

Description: Sets the filter for selecting specific agents for replication.

Parameters:

  • filter - AgentFilter implementation

Example:

java
import com.day.cq.replication.AgentFilter;import com.day.cq.replication.Agent;
ReplicationOptions opts = new ReplicationOptions();
// Filter to specific agentopts.setFilter(new AgentFilter() {    public boolean isIncluded(Agent agent) {        return agent.getId().equals("publish_instance_1");    }});
replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath, opts);

Use cases:

  • Target specific publish instance
  • Exclude certain agents
  • Route content to specific environments
setSuppressVersions(boolean)

Description: Controls whether to create versions during replication.

Parameters:

  • suppress - true to skip version creation, false otherwise

Example:

java
ReplicationOptions opts = new ReplicationOptions();opts.setSuppressVersions(true); // Don't create versions (performance)
setSuppressStatusUpdate(boolean)

Description: Controls whether to update replication status.

Parameters:

  • suppress - true to skip status update, false otherwise

Example:

java
ReplicationOptions opts = new ReplicationOptions();opts.setSuppressStatusUpdate(true); // Don't update status metadata
setRevision(String)

Description: Sets the specific revision to replicate.

Parameters:

  • revision - Revision identifier

Example:

java
ReplicationOptions opts = new ReplicationOptions();opts.setRevision("1.0");replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath, opts);

ReplicationStatus Interface

Provides status information about replicated content.

Official Documentation: ReplicationStatus JavaDoc

Key Methods:

java
// Check if content is activatedboolean isActivated();
// Get last published timestampCalendar getLastPublished();
// Get user who last publishedString getLastPublishedBy();
// Get last replication actionString getLastReplicationAction();
// Get last replicated revisionString getLastReplicatedRevision();

Example:

java
import com.day.cq.replication.ReplicationStatus;import org.apache.sling.api.resource.ResourceResolver;
import javax.jcr.Session;import java.util.HashMap;import java.util.Map;
public Map<String, Object> getReplicationMetadata(ResourceResolver resolver, String path) {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    ReplicationStatus status = replicator.getReplicationStatus(session, path);        Map<String, Object> metadata = new HashMap<>();    if (status != null) {        metadata.put("activated", status.isActivated());        metadata.put("lastPublished", status.getLastPublished());        metadata.put("lastPublishedBy", status.getLastPublishedBy());        metadata.put("lastAction", status.getLastReplicationAction());    }    return metadata;}

Complete Implementation Examples

Example 1: OSGi Service with Replication

java
package com.mycompany.aem.core.services.impl;
import com.day.cq.replication.Replicator;import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import com.day.cq.replication.ReplicationOptions;import org.apache.sling.api.resource.ResourceResolver;import org.osgi.service.component.annotations.Component;import org.osgi.service.component.annotations.Reference;import org.slf4j.Logger;import org.slf4j.LoggerFactory;
import javax.jcr.Session;
@Component(service = ContentPublisher.class, immediate = true)public class ContentPublisherImpl implements ContentPublisher {        private static final Logger LOG = LoggerFactory.getLogger(ContentPublisherImpl.class);        @Reference    private Replicator replicator;        @Override    public boolean publishPage(ResourceResolver resolver, String pagePath) {        try {            Session session = resolver.adaptTo(Session.class);            if (session == null) {                throw new IllegalStateException("Unable to adapt ResourceResolver to Session");            }                        // Create options for synchronous replication            ReplicationOptions opts = new ReplicationOptions();            opts.setSynchronous(true);            opts.setSuppressVersions(false); // Keep version history                        // Activate the page            replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath, opts);                        LOG.info("Successfully activated page: {}", pagePath);            return true;                    } catch (ReplicationException e) {            LOG.error("Failed to activate page: {}", pagePath, e);            return false;        }    }        @Override    public boolean unpublishPage(ResourceResolver resolver, String pagePath) {        try {            Session session = resolver.adaptTo(Session.class);            if (session == null) {                throw new IllegalStateException("Unable to adapt ResourceResolver to Session");            }                        ReplicationOptions opts = new ReplicationOptions();            opts.setSynchronous(true);                        // Deactivate the page            replicator.replicate(session, ReplicationActionType.DEACTIVATE, pagePath, opts);                        LOG.info("Successfully deactivated page: {}", pagePath);            return true;                    } catch (ReplicationException e) {            LOG.error("Failed to deactivate page: {}", pagePath, e);            return false;        }    }}

Example 2: Servlet with Replication

java
package com.mycompany.aem.core.servlets;
import com.day.cq.replication.Replicator;import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;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 javax.jcr.Session;import javax.servlet.Servlet;import java.io.IOException;
@Component(    service = Servlet.class,    property = {        "sling.servlet.methods=POST",        "sling.servlet.paths=/bin/myapp/publish"    })public class PublishServlet extends SlingAllMethodsServlet {        @Reference    private Replicator replicator;        @Override    protected void doPost(SlingHttpServletRequest request,                          SlingHttpServletResponse response) throws IOException {                String path = request.getParameter("path");        String action = request.getParameter("action"); // activate or deactivate                if (path == null || action == null) {            response.setStatus(400);            response.getWriter().write("{\"error\": \"Missing parameters\"}");            return;        }                // Validate path to prevent path traversal        if (!path.startsWith("/content/")) {            response.setStatus(400);            response.getWriter().write("{\"error\": \"Invalid path\"}");            return;        }                try {            Session session = request.getResourceResolver().adaptTo(Session.class);            if (session == null) {                response.setStatus(500);                response.getWriter().write("{\"error\": \"Unable to obtain session\"}");                return;            }                        ReplicationActionType type = "activate".equals(action)                 ? ReplicationActionType.ACTIVATE                 : ReplicationActionType.DEACTIVATE;                        replicator.replicate(session, type, path);                        response.setContentType("application/json");            response.getWriter().write("{\"success\": true, \"path\": \"" + path + "\"}");                    } catch (ReplicationException e) {            response.setStatus(500);            response.getWriter().write("{\"error\": \"" + e.getMessage() + "\"}");        }    }}

Example 3: Workflow Process Step with Replication

java
package com.mycompany.aem.core.workflows;
import com.adobe.granite.workflow.WorkflowException;import com.adobe.granite.workflow.WorkflowSession;import com.adobe.granite.workflow.exec.WorkItem;import com.adobe.granite.workflow.exec.WorkflowProcess;import com.adobe.granite.workflow.metadata.MetaDataMap;import com.day.cq.replication.Replicator;import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import com.day.cq.replication.ReplicationOptions;import org.osgi.service.component.annotations.Component;import org.osgi.service.component.annotations.Reference;import org.slf4j.Logger;import org.slf4j.LoggerFactory;
import javax.jcr.Session;
@Component(    service = WorkflowProcess.class,    property = {        "process.label=Custom Replication Process"    })public class CustomReplicationProcess implements WorkflowProcess {        private static final Logger LOG = LoggerFactory.getLogger(CustomReplicationProcess.class);        @Reference    private Replicator replicator;        @Override    public void execute(WorkItem workItem, WorkflowSession workflowSession,                        MetaDataMap metaDataMap) throws WorkflowException {                String payloadPath = workItem.getWorkflowData().getPayload().toString();        Session session = workflowSession.adaptTo(Session.class);                try {            // Custom replication logic            ReplicationOptions opts = new ReplicationOptions();            opts.setSynchronous(true);                        // Get config from process arguments            String processArgs = metaDataMap.get("PROCESS_ARGS", "");            if ("activate".equals(processArgs)) {                replicator.replicate(session, ReplicationActionType.ACTIVATE, payloadPath, opts);                LOG.info("Workflow activated: {}", payloadPath);            }                    } catch (ReplicationException e) {            LOG.error("Replication failed in workflow", e);            throw new WorkflowException("Replication failed", e);        }    }}

Example 4: Bulk Replication with AgentFilter

java
import com.day.cq.replication.Agent;import com.day.cq.replication.AgentFilter;import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationException;import com.day.cq.replication.ReplicationOptions;import org.apache.sling.api.resource.ResourceResolver;import org.slf4j.Logger;import org.slf4j.LoggerFactory;
import javax.jcr.Session;import java.util.List;
public void bulkActivateToSpecificAgent(ResourceResolver resolver,                                         List<String> paths,                                         String targetAgentId)     throws ReplicationException {        // Validate parameters    if (paths == null || paths.isEmpty()) {        throw new IllegalArgumentException("Path list cannot be null or empty");    }        Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }        // Configure options with agent filter    ReplicationOptions opts = new ReplicationOptions();    opts.setSynchronous(false); // Async for performance    opts.setFilter(new AgentFilter() {        @Override        public boolean isIncluded(Agent agent) {            return agent.getId().equals(targetAgentId);        }    });        // Convert List to array    String[] pathArray = paths.toArray(new String[0]);        // Replicate all paths to specific agent    replicator.replicate(session, ReplicationActionType.ACTIVATE, pathArray, opts);        LOG.info("Bulk activated {} paths to agent: {}", paths.size(), targetAgentId);}

Additional Public APIs

Beyond the core Replicator interface, AEM 6.5 LTS provides additional public APIs for advanced replication management. These are all documented in the official package summary.

AgentManager Interface

Manages replication agents programmatically.

Official Documentation: AgentManager JavaDoc

Key Method:

java
Map<String, Agent> getAgents()

Returns a map of all available agents (agent ID → Agent instance).

Example:

java
import com.day.cq.replication.AgentManager;import com.day.cq.replication.Agent;import org.osgi.service.component.annotations.Reference;
@Referenceprivate AgentManager agentManager;
public void listAllAgents() {    Map<String, Agent> agents = agentManager.getAgents();        for (Map.Entry<String, Agent> entry : agents.entrySet()) {        String agentId = entry.getKey();        Agent agent = entry.getValue();                LOG.info("Agent ID: {}", agentId);        LOG.info("  Enabled: {}", agent.isEnabled());        LOG.info("  Transport URI: {}", agent.getConfiguration().getTransportURI());        LOG.info("  Serialization Type: {}", agent.getConfiguration().getSerializationType());    }}
public Agent getAgentById(String agentId) {    Map<String, Agent> agents = agentManager.getAgents();    return agents.get(agentId);}
public boolean isAgentEnabled(String agentId) {    Agent agent = agentManager.getAgents().get(agentId);    return agent != null && agent.isEnabled();}

ReplicationQueue Interface

Manages replication queue operations programmatically.

Official Documentation: ReplicationQueue JavaDoc

Key Methods:

java
// Get queue nameString getName()
// Get all queue entriesList<ReplicationQueue.Entry> entries()
// Get entries for specific pathList<ReplicationQueue.Entry> entries(String path)
// Get specific entryReplicationQueue.Entry getEntry(String path, Calendar after)
// Clear entire queuevoid clear()
// Clear specific entries by IDvoid clear(Set<String> ids)
// Get queue statusReplicationQueue.Status getStatus()
// Check if pausedboolean isPaused()
// Pause/resume queuevoid setPaused(boolean paused)
// Force retry on blocked entryvoid forceRetry()

Example:

java
import com.day.cq.replication.Agent;import com.day.cq.replication.ReplicationQueue;import com.day.cq.replication.AgentManager;
@Referenceprivate AgentManager agentManager;
public void monitorQueue(String agentId) {    Agent agent = agentManager.getAgents().get(agentId);    if (agent == null) {        LOG.error("Agent not found: {}", agentId);        return;    }        ReplicationQueue queue = agent.getQueue();        // Get queue status    ReplicationQueue.Status status = queue.getStatus();    LOG.info("Queue: {}", queue.getName());    LOG.info("Status: {}", status);    LOG.info("Is Paused: {}", queue.isPaused());        // List all entries    List<ReplicationQueue.Entry> entries = queue.entries();    LOG.info("Queue size: {}", entries.size());        for (ReplicationQueue.Entry entry : entries) {        LOG.info("  Path: {}", entry.getPath());        LOG.info("  Time: {}", entry.getTime());        LOG.info("  ID: {}", entry.getId());    }}
public void clearQueueForPath(String agentId, String path) {    Agent agent = agentManager.getAgents().get(agentId);    if (agent == null) return;        ReplicationQueue queue = agent.getQueue();        // Get entries for specific path    List<ReplicationQueue.Entry> entries = queue.entries(path);        if (entries.isEmpty()) {        LOG.info("No queue entries for path: {}", path);        return;    }        // Collect entry IDs    Set<String> ids = new HashSet<>();    for (ReplicationQueue.Entry entry : entries) {        ids.add(entry.getId());    }        // Clear specific entries    queue.clear(ids);    LOG.info("Cleared {} entries for path: {}", ids.size(), path);}
public void pauseQueue(String agentId) {    Agent agent = agentManager.getAgents().get(agentId);    if (agent != null) {        ReplicationQueue queue = agent.getQueue();        queue.setPaused(true);        LOG.info("Paused queue: {}", queue.getName());    }}
public void forceRetryBlockedQueue(String agentId) {    Agent agent = agentManager.getAgents().get(agentId);    if (agent != null) {        ReplicationQueue queue = agent.getQueue();        queue.forceRetry();        LOG.info("Forced retry on queue: {}", queue.getName());    }}

ReplicationListener Interface

Listens for replication events in real-time.

Official Documentation: ReplicationListener JavaDoc

Methods:

java
// Called before replication startsvoid onStart(Agent agent, ReplicationAction action)
// Called when log message writtenvoid onMessage(ReplicationLog.Level level, String message)
// Called when replication completesvoid onEnd(Agent agent, ReplicationAction action, ReplicationResult result)
// Called on replication errorvoid onError(Agent agent, ReplicationAction action, Exception exception)

Example:

java
import com.day.cq.replication.ReplicationListener;import com.day.cq.replication.Agent;import com.day.cq.replication.ReplicationAction;import com.day.cq.replication.ReplicationResult;import com.day.cq.replication.ReplicationLog;import org.slf4j.Logger;import org.slf4j.LoggerFactory;
public class CustomReplicationListener implements ReplicationListener {        private static final Logger LOG = LoggerFactory.getLogger(CustomReplicationListener.class);        @Override    public void onStart(Agent agent, ReplicationAction action) {        LOG.info("Replication starting - Agent: {}, Path: {}, Type: {}",             agent.getId(),             action.getPath(),             action.getType());    }        @Override    public void onMessage(ReplicationLog.Level level, String message) {        switch (level) {            case DEBUG:                LOG.debug("Replication: {}", message);                break;            case INFO:                LOG.info("Replication: {}", message);                break;            case WARN:                LOG.warn("Replication: {}", message);                break;            case ERROR:                LOG.error("Replication: {}", message);                break;        }    }        @Override    public void onEnd(Agent agent, ReplicationAction action, ReplicationResult result) {        LOG.info("Replication completed - Agent: {}, Path: {}, Success: {}",             agent.getId(),             action.getPath(),             result.isSuccess());                    // Send notification, update metrics, etc.        if (result.isSuccess()) {            // Success handling            notifySuccess(action.getPath());        }    }        @Override    public void onError(Agent agent, ReplicationAction action, Exception exception) {        LOG.error("Replication failed - Agent: {}, Path: {}",             agent.getId(),             action.getPath(),             exception);                    // Error handling, alerts, retry logic        alertReplicationFailure(action.getPath(), exception);    }        private void notifySuccess(String path) {        // Custom notification logic    }        private void alertReplicationFailure(String path, Exception e) {        // Custom alert logic    }}
// Using listener with Replicator@Referenceprivate Replicator replicator;
public void replicateWithListener(ResourceResolver resolver, String path)     throws ReplicationException {        Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }        ReplicationOptions opts = new ReplicationOptions();    opts.setSynchronous(true);        // Attach custom listener    CustomReplicationListener listener = new CustomReplicationListener();    opts.setListener(listener);        replicator.replicate(session, ReplicationActionType.ACTIVATE, path, opts);}

AgentFilter Interface

Filters agents for selective replication (detailed earlier).

Official Documentation: AgentFilter JavaDoc

Method:

java
boolean isIncluded(Agent agent)

Static Fields:

  • AgentFilter.DEFAULT - Filter for non-specific agents
  • AgentFilter.OUTBOX_AGENT_FILTER - Filter for distribution operations

Advanced Example:

java
import com.day.cq.replication.AgentFilter;import com.day.cq.replication.Agent;import com.day.cq.replication.ReplicationActionType;import com.day.cq.replication.ReplicationOptions;
import java.util.Arrays;import java.util.HashSet;import java.util.Set;
// Filter by multiple criteriapublic class CustomAgentFilter implements AgentFilter {        private final Set<String> allowedAgentIds;    private final String requiredTransportProtocol;        public CustomAgentFilter(Set<String> allowedAgentIds, String protocol) {        this.allowedAgentIds = allowedAgentIds;        this.requiredTransportProtocol = protocol;    }        @Override    public boolean isIncluded(Agent agent) {        // Filter by agent ID        if (!allowedAgentIds.contains(agent.getId())) {            return false;        }                // Filter by enabled status        if (!agent.isEnabled()) {            return false;        }                // Filter by transport protocol        String transportURI = agent.getConfiguration().getTransportURI();        if (transportURI != null && !transportURI.startsWith(requiredTransportProtocol)) {            return false;        }                return true;    }}
// UsageSet<String> allowedAgents = new HashSet<>(Arrays.asList("publish1", "publish2"));AgentFilter filter = new CustomAgentFilter(allowedAgents, "https://");
ReplicationOptions opts = new ReplicationOptions();opts.setFilter(filter);
replicator.replicate(session, ReplicationActionType.ACTIVATE, path, opts);

Agent Interface

Represents a replication agent.

Official Documentation: Agent JavaDoc

Key Methods:

java
String getId()                    // Get agent IDboolean isEnabled()               // Check if enabledAgentConfig getConfiguration()    // Get configurationReplicationQueue getQueue()       // Get agent's queueboolean isConnected()             // Check connectivity status

Example:

java
public void inspectAgent(String agentId) {    Agent agent = agentManager.getAgents().get(agentId);        if (agent == null) {        LOG.error("Agent not found: {}", agentId);        return;    }        LOG.info("Agent Details:");    LOG.info("  ID: {}", agent.getId());    LOG.info("  Enabled: {}", agent.isEnabled());    LOG.info("  Connected: {}", agent.isConnected());        AgentConfig config = agent.getConfiguration();    LOG.info("  Transport URI: {}", config.getTransportURI());    LOG.info("  Serialization: {}", config.getSerializationType());    LOG.info("  User: {}", config.getTransportUser());        ReplicationQueue queue = agent.getQueue();    LOG.info("  Queue Name: {}", queue.getName());    LOG.info("  Queue Size: {}", queue.entries().size());    LOG.info("  Queue Status: {}", queue.getStatus());}

Exception Handling

ReplicationException Hierarchy

java
try {    replicator.replicate(session, ReplicationActionType.ACTIVATE, path);    } catch (ReplicationException e) {    // Base exception for all replication errors    LOG.error("Replication failed", e);        // Common causes:    // - Agent not found    // - Agent disabled or blocked    // - Network connectivity issues    // - Permission denied    // - Target instance unavailable}

Best Practices for Exception Handling:

java
public ReplicationResult safeReplicate(ResourceResolver resolver, String path) {    try {        // Check permissions first        Session session = resolver.adaptTo(Session.class);        if (session == null) {            throw new IllegalStateException("Unable to adapt ResourceResolver to Session");        }        replicator.checkPermission(session, ReplicationActionType.ACTIVATE, path);                // Perform replication        ReplicationOptions opts = new ReplicationOptions();        opts.setSynchronous(true);        replicator.replicate(session, ReplicationActionType.ACTIVATE, path, opts);                return ReplicationResult.success(path);            } catch (ReplicationException e) {        LOG.error("Replication failed for path: {}", path, e);        return ReplicationResult.failure(path, e.getMessage());    }}

Error Handling Patterns

Choose the appropriate error handling pattern based on your use case.

Pattern 1: Throw Exceptions (Library Code)

When to use:

  • Library/utility methods
  • Workflow process steps
  • OSGi services called by other components
  • When caller needs to handle errors differently

Characteristics:

  • Propagates errors to caller
  • Caller decides error handling strategy
  • Most flexible for reuse

Example:

java
public void activatePage(ResourceResolver resolver, String pagePath)     throws ReplicationException {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath);    // Throws ReplicationException on failure}

Caller handles the exception:

java
try {    activatePage(resolver, path);    LOG.info("Page activated successfully: {}", path);} catch (ReplicationException e) {    LOG.error("Activation failed: {}", path, e);    // Caller-specific error handling (retry, alert, etc.)}

Pattern 2: Return Boolean (Service Layer)

When to use:

  • Service layer with internal error logging
  • Fire-and-forget operations
  • When caller only needs success/failure indicator
  • Background/scheduled jobs

Characteristics:

  • Logs errors internally
  • Returns simple success/failure flag
  • Caller doesn't need exception details

Example:

java
public boolean activatePage(ResourceResolver resolver, String pagePath) {    try {        Session session = resolver.adaptTo(Session.class);        if (session == null) {            LOG.error("Unable to adapt ResourceResolver to Session");            return false;        }                replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath);        LOG.info("Page activated: {}", pagePath);        return true;            } catch (ReplicationException e) {        LOG.error("Replication failed for: {}", pagePath, e);        return false;    }}

Caller usage:

java
if (activatePage(resolver, path)) {    // Success path    updateAuditLog(path, "activated");} else {    // Failure path    updateAuditLog(path, "activation_failed");}

Pattern 3: HTTP Status Codes (Servlets and REST APIs)

When to use:

  • Sling servlets
  • REST API endpoints
  • Web service integrations
  • HTTP-based interfaces

Characteristics:

  • Communicates errors via HTTP status codes
  • Returns error details in response body
  • Standard web semantics

Example:

java
@Component(    service = Servlet.class,    property = {        "sling.servlet.methods=POST",        "sling.servlet.paths=/bin/myapp/replicate"    })public class ReplicationServlet extends SlingAllMethodsServlet {        @Reference    private Replicator replicator;        @Override    protected void doPost(SlingHttpServletRequest request,                          SlingHttpServletResponse response) throws IOException {                String path = request.getParameter("path");                // Validate parameters        if (path == null || path.trim().isEmpty()) {            response.setStatus(HttpServletResponse.SC_BAD_REQUEST);            response.getWriter().write("{\"error\": \"Missing required parameter: path\"}");            return;        }                // Validate path        if (!path.startsWith("/content/")) {            response.setStatus(HttpServletResponse.SC_BAD_REQUEST);            response.getWriter().write("{\"error\": \"Invalid path: must start with /content/\"}");            return;        }                try {            Session session = request.getResourceResolver().adaptTo(Session.class);            if (session == null) {                response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);                response.getWriter().write("{\"error\": \"Unable to obtain session\"}");                return;            }                        replicator.replicate(session, ReplicationActionType.ACTIVATE, path);                        response.setStatus(HttpServletResponse.SC_OK);            response.getWriter().write("{\"success\": true, \"path\": \"" + path + "\"}");                    } catch (ReplicationException e) {            LOG.error("Replication failed", e);            response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);            response.getWriter().write("{\"error\": \"" + e.getMessage() + "\"}");        }    }}

Pattern Comparison

PatternUse CaseError DetailsCaller ControlExample Context
Throw ExceptionLibrary codeFull stack traceHigh - caller handlesUtility methods, workflow steps
Return BooleanService layerLogged internallyLow - success/fail onlyBackground jobs, scheduled tasks
HTTP StatusWeb interfacesJSON error responseMedium - status code + messageREST APIs, servlets

Choosing the Right Pattern

Use Throw Exception when:

  • Building reusable library code
  • Caller needs detailed error information
  • Different callers need different error handling
  • Workflow process steps (WorkflowProcess interface)

Use Return Boolean when:

  • Errors are logged and monitored centrally
  • Caller only needs success/failure indicator
  • Fire-and-forget operations
  • Scheduled/background jobs

Use HTTP Status when:

  • Building HTTP endpoints (servlets, REST)
  • Web service integrations
  • Following REST API conventions
  • Client needs machine-readable error codes

Anti-Patterns to Avoid

Don't mix patterns:

java
// BAD: Returning boolean but also throwing exceptionpublic boolean activatePage(String path) throws ReplicationException {    // Confusing - which error handling mechanism?}

Don't swallow exceptions silently:

java
// BAD: Silent failuretry {    replicator.replicate(session, type, path);} catch (ReplicationException e) {    // No logging, no error indication}return true; // Always returns true, even on failure

Don't use generic exceptions:

java
// BAD: Generic exception loses contextpublic void activate(String path) throws Exception {    // Caller can't distinguish ReplicationException from other errors}

Do be specific:

java
// GOOD: Specific exception typepublic void activate(String path) throws ReplicationException {    // Caller knows exactly what failed}

Security Considerations

1. Use Service Users

Never use admin sessions. Create dedicated service users:

Service User Mapping OSGi Configuration:

Create file: ui.config/src/main/content/jcr_root/apps/myapp/osgiconfig/config.author/org.apache.sling.serviceusermapping.impl.ServiceUserMapperImpl.amended-replication.cfg.json

json
{  "user.mapping": [    "com.mycompany.aem.core:replication-service=replication-service"  ]}

Service User Permissions:

The service user replication-service requires:

  • Read permissions on /content, /conf
  • Replicate permissions on paths to be activated
  • Write permissions on /var/replication/outbox (for reverse replication)
java
import org.apache.sling.api.resource.ResourceResolverFactory;import org.apache.sling.api.resource.ResourceResolver;
@Referenceprivate ResourceResolverFactory resolverFactory;
public void replicateWithServiceUser(String path) throws ReplicationException {    Map<String, Object> authInfo = new HashMap<>();    authInfo.put(ResourceResolverFactory.SUBSERVICE, "replication-service");        try (ResourceResolver resolver = resolverFactory.getServiceResourceResolver(authInfo)) {        Session session = resolver.adaptTo(Session.class);        if (session == null) {            throw new IllegalStateException("Unable to adapt ResourceResolver to Session");        }        replicator.replicate(session, ReplicationActionType.ACTIVATE, path);    } catch (LoginException e) {        LOG.error("Service user login failed", e);    }}

2. Permission Checks

Always verify permissions before replication:

java
public boolean activateIfAllowed(ResourceResolver resolver, String path) {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }        try {        // Check permission first        replicator.checkPermission(session, ReplicationActionType.ACTIVATE, path);                // Permission granted, proceed        replicator.replicate(session, ReplicationActionType.ACTIVATE, path);        return true;            } catch (ReplicationException e) {        LOG.warn("User lacks replication permission for: {}", path);        return false;    }}

3. Input Validation

Validate paths and parameters:

java
public void safeActivate(ResourceResolver resolver, String path)     throws IllegalArgumentException, ReplicationException {        // Validate path    if (path == null || path.trim().isEmpty()) {        throw new IllegalArgumentException("Path cannot be null or empty");    }        // Ensure path is under /content    if (!path.startsWith("/content/")) {        throw new IllegalArgumentException("Invalid path: must be under /content");    }        // Check resource exists    Resource resource = resolver.getResource(path);    if (resource == null) {        throw new IllegalArgumentException("Resource not found: " + path);    }        // Validate resource type is replicable    if (!isReplicableResource(resource)) {        throw new IllegalArgumentException(            "Resource is not replicable. Must be cq:Page or dam:Asset, found: "             + resource.getResourceType());    }        // Safe to replicate    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    replicator.replicate(session, ReplicationActionType.ACTIVATE, path);}
/** * Validates if a resource is a replicable content type. *  * <p>This method checks if the resource represents content that should be replicated * to publish instances. Only standard AEM content types (pages, assets, experience fragments) * are considered replicable. System and configuration resources are excluded to prevent * unintended replication of application code or configuration.</p> *  * <p><strong>Allowed resource types:</strong></p> * <ul> *   <li><code>cq:Page</code> - Standard AEM pages and their hierarchies</li> *   <li><code>dam:Asset</code> - Digital Asset Manager (DAM) assets including images, videos, documents</li> *   <li><code>cq:PageContent</code> under <code>/content/experience-fragments/</code> - Experience fragments for content reuse</li> * </ul> *  * <p><strong>Excluded paths:</strong> Resources under <code>/apps</code>, <code>/libs</code>, * <code>/etc/designs</code>, <code>/var</code>, and other system paths are implicitly excluded * by only accepting the types above.</p> *  * @param resource the resource to validate (must not be null) * @return {@code true} if the resource is a standard content type that should be replicated; *         {@code false} if it is a system/configuration resource or unsupported type * @see <a href="https://experienceleague.adobe.com/en/docs/experience-manager-65-lts/content/implementing/deploying/configuring/replication">AEM Replication Documentation</a> */private boolean isReplicableResource(Resource resource) {    String resourceType = resource.getResourceType();        // Check if it's a page    if (resource.isResourceType("cq:Page")) {        return true;    }        // Check if it's a DAM asset    if (resource.isResourceType("dam:Asset")) {        return true;    }        // Check if it's an experience fragment    if (resource.isResourceType("cq:PageContent") &&         resource.getPath().startsWith("/content/experience-fragments/")) {        return true;    }        // System/config resources should not be replicated    return false;}

ResourceResolver Lifecycle Management

Caller Responsibility Pattern

Important: When accepting ResourceResolver as a method parameter, the caller is responsible for closing it, not the method.

java
/** * Activates a page using the replication API. *  * @param resolver ResourceResolver (caller must close) * @param pagePath Path to the page to activate * @throws ReplicationException if replication fails */public void activatePage(ResourceResolver resolver, String pagePath)     throws ReplicationException {    Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }    replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath);    // Do NOT close resolver here - caller owns it}

Caller usage:

java
ResourceResolver resolver = null;try {    resolver = resolverFactory.getServiceResourceResolver(authInfo);    activatePage(resolver, "/content/mysite/en/page");} catch (LoginException e) {    LOG.error("Service user login failed", e);} catch (ReplicationException e) {    LOG.error("Replication failed", e);} finally {    if (resolver != null && resolver.isLive()) {        resolver.close(); // Caller closes    }}

Try-with-Resources Pattern (Recommended)

When creating the ResourceResolver within your method, use try-with-resources for automatic cleanup:

java
public void activateWithServiceUser(String pagePath) throws ReplicationException {    Map<String, Object> authInfo = new HashMap<>();    authInfo.put(ResourceResolverFactory.SUBSERVICE, "replication-service");        try (ResourceResolver resolver = resolverFactory.getServiceResourceResolver(authInfo)) {        Session session = resolver.adaptTo(Session.class);        if (session == null) {            throw new IllegalStateException("Unable to adapt ResourceResolver to Session");        }        replicator.replicate(session, ReplicationActionType.ACTIVATE, pagePath);    } catch (LoginException e) {        LOG.error("Service user login failed", e);        throw new ReplicationException("Authentication failed", e);    }    // ResourceResolver auto-closed here}

Resource Leak Prevention

Common mistake - Resource leak:

java
// BAD: Resolver never closedpublic void activatePage(String path) throws ReplicationException {    ResourceResolver resolver = resolverFactory.getServiceResourceResolver(authInfo);    Session session = resolver.adaptTo(Session.class);    replicator.replicate(session, ReplicationActionType.ACTIVATE, path);    // LEAK: resolver not closed}

Correct pattern:

java
// GOOD: Try-with-resources ensures cleanuppublic void activatePage(String path) throws ReplicationException {    Map<String, Object> authInfo = new HashMap<>();    authInfo.put(ResourceResolverFactory.SUBSERVICE, "replication-service");        try (ResourceResolver resolver = resolverFactory.getServiceResourceResolver(authInfo)) {        Session session = resolver.adaptTo(Session.class);        if (session == null) {            throw new IllegalStateException("Unable to adapt ResourceResolver to Session");        }        replicator.replicate(session, ReplicationActionType.ACTIVATE, path);    } catch (LoginException e) {        LOG.error("Service user login failed", e);        throw new ReplicationException("Authentication failed", e);    }}

Manual Close Pattern (Legacy)

If try-with-resources is not an option (pre-Java 7 code):

java
public void activatePage(String path) throws ReplicationException {    ResourceResolver resolver = null;    try {        Map<String, Object> authInfo = new HashMap<>();        authInfo.put(ResourceResolverFactory.SUBSERVICE, "replication-service");        resolver = resolverFactory.getServiceResourceResolver(authInfo);                Session session = resolver.adaptTo(Session.class);        if (session == null) {            throw new IllegalStateException("Unable to adapt ResourceResolver to Session");        }        replicator.replicate(session, ReplicationActionType.ACTIVATE, path);            } catch (LoginException e) {        LOG.error("Service user login failed", e);        throw new ReplicationException("Authentication failed", e);    } finally {        if (resolver != null && resolver.isLive()) {            resolver.close();        }    }}

Best Practices

  1. Prefer try-with-resources for all new code
  2. Document ownership with JavaDoc when accepting ResourceResolver as parameter
  3. Always check isLive() before closing in finally blocks
  4. Never close a ResourceResolver you didn't create
  5. Use service users - never create admin ResourceResolvers

Performance Optimization

1. Use Asynchronous Replication for Bulk Operations

java
public void bulkActivate(ResourceResolver resolver, List<String> paths)     throws ReplicationException {        Session session = resolver.adaptTo(Session.class);    if (session == null) {        throw new IllegalStateException("Unable to adapt ResourceResolver to Session");    }        ReplicationOptions opts = new ReplicationOptions();    opts.setSynchronous(false); // Non-blocking for better performance    opts.setSuppressVersions(true); // Skip versioning to reduce overhead        String[] pathArray = paths.toArray(new String[0]);    replicator.replicate(session, ReplicationActionType.ACTIVATE, pathArray, opts);}

2. Batch Multiple Paths

Use array variants instead of looping:

java
// BAD: Individual calls in loopfor (String path : paths) {    replicator.replicate(session, ReplicationActionType.ACTIVATE, path);}
// GOOD: Single batch callString[] pathArray = paths.toArray(new String[0]);replicator.replicate(session, ReplicationActionType.ACTIVATE, pathArray, opts);

3. Suppress Unnecessary Operations

java
ReplicationOptions opts = new ReplicationOptions();opts.setSuppressVersions(true); // Don't create versionsopts.setSuppressStatusUpdate(false); // Keep status tracking

Testing and Validation

Unit Testing with Mocks

java
import org.junit.jupiter.api.Test;import org.junit.jupiter.api.extension.ExtendWith;import org.mockito.InjectMocks;import org.mockito.Mock;import org.mockito.junit.jupiter.MockitoExtension;
import static org.mockito.ArgumentMatchers.*;import static org.mockito.Mockito.*;
@ExtendWith(MockitoExtension.class)class ContentPublisherTest {        @Mock    private Replicator replicator;        @Mock    private ResourceResolver resolver;        @Mock    private Session session;        @InjectMocks    private ContentPublisherImpl contentPublisher;        @Test    void testPublishPage() throws Exception {        when(resolver.adaptTo(Session.class)).thenReturn(session);                String path = "/content/mysite/en/page";        boolean result = contentPublisher.publishPage(resolver, path);                assertTrue(result);        verify(replicator).replicate(            eq(session),            eq(ReplicationActionType.ACTIVATE),            eq(path),            any(ReplicationOptions.class)        );    }}

Troubleshooting

Common Issues:

Issue: ReplicationException - Agent not found

Solution: Verify replication agents are configured and enabledCheck: /etc/replication/agents.author

Issue: Permission denied

Solution: Grant replication privileges to service userCheck: User permissions on content path and crx:replicate privilege

Issue: Synchronous replication times out

Solution: 1. Use asynchronous replication for large operations2. Increase timeout in replication agent configuration3. Check Publish instance performance

Issue: Content not appearing on Publish

Solution:1. Check replication queue status2. Verify Dispatcher Flush agent is working3. Check Publish instance logs4. Use getReplicationStatus() to verify activation

Related Skills

  • configure-replication-agent: Set up replication agents
  • replicate-content: UI-based content activation methods
  • troubleshoot-replication: Diagnose and fix replication issues

Success Criteria

  • ✓ Successfully integrated Replicator service via OSGi reference
  • ✓ Programmatic activation/deactivation working
  • ✓ ReplicationOptions configured correctly
  • ✓ Permission checks implemented
  • ✓ Exception handling in place
  • ✓ Service user configured with proper permissions
  • ✓ Unit tests passing with mocked Replicator
  • ✓ Replication status can be queried
  • ✓ Content appears on Publish after API call
  • ✓ Logs show successful replication entries

Additional Resources

來源與署名

來源：adobe/skills位於plugins/aem/6.5-lts/skills/aem-replication/replication-api提交940b879

授權條款： Apache-2.0

內容歸原作者所有。SourceWeft 從公開儲存庫中收錄這些內容。

檢舉或申請下架

更多來自 adobe/skills 的技能

Technical Advisory

adobe

為 AEMaaCS 雲端環境的 Adobe Dispatcher 與 HTTPD 設定提供諮詢建議，附引用與 MCP 驗證計畫。

DevOps & Cloud197今天更新

Security Hardening

adobe

針對 AEMaaCS 雲端工作流程中的 Adobe Dispatcher 與 Apache HTTPD 執行有證據支撐的安全稽核與強化驗證。

Security197今天更新

Performance Tuning

adobe

使用 Dispatcher MCP 工具為 AEMaaCS 雲端部署調校 Adobe Dispatcher 與 HTTPD 設定效能。

DevOps & Cloud197今天更新

Incident Response

adobe

使用執行階段 MCP 證據，調查並分診 AEM as a Cloud Service 中 Adobe Dispatcher 的執行階段事件。

DevOps & Cloud197今天更新

Config Authoring

adobe

為 AEM as a Cloud Service 撰寫、審查並強化 Adobe Dispatcher 與 Apache HTTPD 設定。

DevOps & Cloud197今天更新

Dispatcher

adobe

將 AEM as a Cloud Service Dispatcher 請求路由到設定、事故、調校與加固等專項技能。

DevOps & Cloud197今天更新

更多Software Development技能

Playground

anthropics

精選

建立自成一體的互動式 HTML 遊樂場，包含控制項、即時預覽與可複製的提示詞輸出。

Software Development37K今天更新

M5 Onboard

anthropics

精選

透過 USB 偵測 M5Stack ESP32 開發板，燒錄 UIFlow 2.0 韌體並安裝 MicroPython 應用程式套件。

Software Development37K今天更新

Cardputer Buddy

anthropics

精選

指導迭代 Cardputer-Adv 的 MicroPython 應用程式套件：新增應用程式、透過 USB 序列埠推送檔案、查看日誌並執行 REPL 指令。

Software Development37K今天更新

Web Design Guidelines

vercel-labs

精選

依據從遠端來源取得的 Web Interface Guidelines 審查 UI 程式碼，並以 file:line 形式回報問題。

Software Development32K5 週前更新

Vercel React Native Skills

vercel-labs

精選

React Native 與 Expo 最佳實務規則，涵蓋清單效能、動畫、導覽、UI 模式、狀態與 monorepo 設定。

Software Development32K5 週前更新

Vercel React Best Practices

vercel-labs

精選

Vercel 的 React 與 Next.js 效能指南，以 70 條規則的形式用於撰寫、審查與重構程式碼。

Software Development32K5 週前更新