global class SampleExternalBatch implements Database.Batchable, Database.Stateful{
		private Id cloudMDMJobQueueId = null; 			
		private Integer itemProcessed = 0; 			
		private Integer totalJobItem = 1000; 			
		
		global Database.QueryLocator start(Database.BatchableContext BC) { 				
			cloudMDMJobQueueId = API_QueueManager.start(BC);
			List<string> accountNames = API_QueueManager.getExtendedParameters (cloudMDMJobQueueId, 'AccountName'); 
			List<string> billingCountry = API_QueueManager.getExtendedParameters (cloudMDMJobQueueId, 'BillingCountry');
			API_QueueManager.UpdateStatus(cloudMDMJobQueueId, 'start', 0);

			return Database.getQueryLocator(<>); 			
		} 			
		
		global void execute(Database.BatchableContext BC, List scope) { 				
			itemProcessed = itemProcessed + scope.size(); 				
			API_QueueManager.updateExecutionProgress(cloudMDMJobQueueId,  totalJobItem, itemProcessed); 			
		} 			
		
		global void finish(Database.BatchableContext BC) { 				
			API_QueueManager.finish(cloudMDMJobQueueId, BATCH_STATUS.SUCCESS); 			
		} 		
	}

Submit a batch job to the

CC360

batch queue.

The following code example shows how to submit jobs into the

CC360

batch queue:

 
	API_QueueManager qManager = new API_QueueManager ('CustomBatch', 'ETL_CustomApexBatchJob');
	qManager.setQuickParameters (new List<string>{'PARAM1', 'PARAM2', 'PARAM3', 'PARAM4', 'PARAM5', 'PARAM6', 'PARAM7', 'PARAM8'});
 	qManager.pushExtendedParameters('AccountName', new List<string>{'Informatica', 'EcoLab'});
 	qManager.pushExtendedParameters('BillingCountry', new List<string>{'USA', 'UK'});
 	Id batchJobQueueId = qManager.submitJob();

Register loop batch jobs.

The following code example shows how to register batch loop jobs:

global void finish(Database.BatchableContext BC) { 				

	// If more record to process register and loop next chunk or batch
	if (moreRecordsToProcess ())
	{
		Id newLoopJobId = API_QueueManager.registerJobLoop(
						cloudMDMJobQueueId);
		API_QueueManager.submitJob (newLoopJobId);
	}
	else 
	{
	// no more pending records to process. Mark current job as complete
		API_QueueManager.finish(cloudMDMJobQueueId, 
					BATCH_STATUS.SUCCESS); 			
	}
}