anchor.diff:      begin
         newjob := batchexec.QueueJob;
         newjob.Description:= aTables.Get(i).DestinationTableName;
  +      newjob.Application:= aApplication;
         newjob.DoJobProcedure := InternalReplicaTable;
         tmpJobData := TJobData.Create;
         jobDataList.Add(tmpJobData);
  
positive.code:   TReplicaEngine = class
    strict private
      FCanTerminate : boolean;
  
      procedure InternalReplicaTable (aProgress: ImProgress; aData : TObject; aJobResult : TJobResult);
      procedure DoTerminate(const aJobsResult : TJobResults);
    public
      function ProcessTables ({$ifdef gui}aParentForm : TForm;{$endif} const aTables : TDataReplicaTables; const aResults : IPerformedOperationResults = nil; const aMaxConcurrentThreads : integer = -1) : boolean;
    end;
  
    function DoReplicaTable (const aTable : TDataReplicaTableToTable; aProgress: ImProgress; aResults : IPerformedOperationResults) : boolean;
  
negative.code: {$I mDefines.inc}
  
  uses
    DB, Classes, CustApp, {$IFDEF GUI}Forms,{$ENDIF}
    mDatabaseConnection, mDatabaseConnectionClasses,
    mProgress, mThreads, mPerformedOperationResults,
    mDataPumpConfiguration;
  