Your achievements

Level 1

0% to

Level 2

Tip /
Sign in

Sign in to Community

to gain points, level up, and earn exciting badges like the new
Bedrock Mission!

Learn more

View all

Sign in to view all badges

SOLVED

Calling a specific Replication Agent in Workflow Process which Activates Pages

Avatar

Level 2

I have a custom workflow process to activate content, I want to replicate my content to a specific publisher using a specific replication agent(with Agent user ID). I'm not getting how I can use this to achieve my goal.

Can anyone please help me with code snippet or the java method or class which may be helpful in achieving this.

Topics

Topics help categorize Community content and increase your ability to discover relevant content.

1 Accepted Solution

Avatar

Correct answer by
Community Advisor

Hi @avi_infy,

You can achieve your goal using replication api:

First you will need to know replication agent id you would like to use, you can check this under /miscadmin#/etc/replication/agents.author, getting value from Name column

replication-agents.jpg

Next you can use below snippet of the code. It use AgentIdFilter to use only specific replication Agent. Below is sample workflow step, you may need to change the way how you are getting path you wanted to replicate, as well as agent id. But it should give you clear idea how to use replication api. Please also make sure workflow user you are using has replication permission.

package com.mysite.core.workflow;

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.*;

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

import javax.jcr.Session;

@Component(
        service = WorkflowProcess.class,
        property = "process.label=CustomReplicationStep"
)
public class ReplicationStep implements WorkflowProcess {

    @Reference
    private Replicator replicator;

    private final static String agentId = "publish2";

    @Override
    public void execute(WorkItem workItem, WorkflowSession workflowSession, MetaDataMap metaDataMap) throws WorkflowException {
        AgentIdFilter agentIdFilter = new AgentIdFilter(agentId);
        ReplicationOptions replicationOptions = new ReplicationOptions();
        replicationOptions.setFilter(agentIdFilter);

        String path = workItem.getWorkflowData().getPayload().toString();

        try {
            replicator.replicate(workflowSession.adaptTo(Session.class),
                    ReplicationActionType.ACTIVATE, path, replicationOptions);
        } catch (ReplicationException e) {
            e.printStackTrace();
        }
    }
}

 

View solution in original post

2 Replies

Avatar

Correct answer by
Community Advisor

Hi @avi_infy,

You can achieve your goal using replication api:

First you will need to know replication agent id you would like to use, you can check this under /miscadmin#/etc/replication/agents.author, getting value from Name column

replication-agents.jpg

Next you can use below snippet of the code. It use AgentIdFilter to use only specific replication Agent. Below is sample workflow step, you may need to change the way how you are getting path you wanted to replicate, as well as agent id. But it should give you clear idea how to use replication api. Please also make sure workflow user you are using has replication permission.

package com.mysite.core.workflow;

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.*;

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

import javax.jcr.Session;

@Component(
        service = WorkflowProcess.class,
        property = "process.label=CustomReplicationStep"
)
public class ReplicationStep implements WorkflowProcess {

    @Reference
    private Replicator replicator;

    private final static String agentId = "publish2";

    @Override
    public void execute(WorkItem workItem, WorkflowSession workflowSession, MetaDataMap metaDataMap) throws WorkflowException {
        AgentIdFilter agentIdFilter = new AgentIdFilter(agentId);
        ReplicationOptions replicationOptions = new ReplicationOptions();
        replicationOptions.setFilter(agentIdFilter);

        String path = workItem.getWorkflowData().getPayload().toString();

        try {
            replicator.replicate(workflowSession.adaptTo(Session.class),
                    ReplicationActionType.ACTIVATE, path, replicationOptions);
        } catch (ReplicationException e) {
            e.printStackTrace();
        }
    }
}