code: private void initApplyPersistedChangesTask()
     {
        applyPersistedChangesTask = new RemoteCommand()
        {
           /**
            * {@inheritDoc}
            */
           public String getId()
           {
              return "ChangesListener-" + uniqueName + "-applyPersistedChangesTask";
           }
  
           /**
            * Accumulates persisted changes.
            */
           public Serializable execute(final Serializable[] args) throws Throwable
           {
              ChangesItem changesItem = (ChangesItem)args[0];
  
              Runnable task = new ApplyPersistedChangesTask(wqm.getContext(), changesItem);
              executor.execute(task);
  
              return null;
           }
        };
     }
docs: Initialize remote command {@link #applyPersistedChangesTask}