Automatically synchronizing staging and integration tasks | Kentico Xperience 11 Documentation

This content cannot be displayed without JavaScript.
Please enable JavaScript and reload the page.

Automatically synchronizing staging and integration tasks | Kentico Xperience 11 Documentation

using CMS;
using CMS.DataEngine;
using CMS.Synchronization;
using CMS.SynchronizationEngine;

// Registers the custom module into the system
[assembly: RegisterModule(typeof(LogTaskHandlerModule))]

public class LogTaskHandlerModule : Module
{
    // Module class constructor, the system registers the module under the name "LogTaskHandlers"
    public LogTaskHandlerModule()
        : base("LogTaskHandlers")
    {
    }

    // Contains initialization code that is executed when the application starts
    protected override void OnInit()
    {
        base.OnInit();

        // Assigns a handler to the StagingEvents.LogTask.After event
        // This event occurs after the system creates content staging synchronization tasks (separately for each task)
        StagingEvents.LogTask.After += LogStagingTask_After;

        // Assigns a handler to the IntegrationEvents.LogInternalTask.After event
        // This event occurs after the system creates outgoing integration tasks (separately for each task)
        IntegrationEvents.LogInternalTask.After += LogIntegrationTask_After;
    }
}

Define the handler methods (inside the custom module class):

C#

// Automatically synchronizes staging tasks
private void LogStagingTask_After(object sender, StagingTaskEventArgs e)
{
    if (e.Task != null)
    {
        // Gets the identifiers of the staging servers for which the task was created
        var taskServerIds = SynchronizationInfoProvider.GetSynchronizations()
                                                                .Column("SynchronizationServerID")
                                                                .WhereEquals("SynchronizationTaskID", e.Task.TaskID);

        // Gets the task's staging servers based on the retrieved identifiers
        var targetServers = ServerInfoProvider.GetServers().WhereIn("ServerID", taskServerIds);

        // Processes the task for all relevant servers
        foreach (ServerInfo server in targetServers)
        {
            // Synchronizes the processed staging task to the target server
            new StagingTaskRunner(server.ServerID).RunSynchronization(e.Task.TaskID);
        }
    }
}

// Automatically synchronizes outgoing integration tasks
private void LogIntegrationTask_After(object sender, IntegrationTaskEventArgs e)
{
    // Gets the info object for an integration connector
    IntegrationConnectorInfo connectorInfo = IntegrationConnectorInfoProvider.GetIntegrationConnectorInfo("MyConnector");

    if ((connectorInfo != null) && (e.Task != null))
    {
        // Gets an instance of the integration connector class
        BaseIntegrationConnector connector = IntegrationHelper.GetConnector(connectorInfo.ConnectorName) as BaseIntegrationConnector;

        // Synchronizes the processed integration task
        connector.ProcessInternalTask(e.Task);
    }
}