Transaction Finalizers

1global void execute(System.FinalizerContext ctx) {}

1public class LoggingFinalizer implements Finalizer, Queueable {
2
3  // Queueable implementation
4  // A queueable job that uses LoggingFinalizer to buffer the log
5  // and commit upon exit, even if the queueable execution fails
6
7    public void execute(QueueableContext ctx) {
8        String jobId = '' + ctx.getJobId();
9        System.debug('Begin: executing queueable job: ' + jobId);
10        try {
11            // Create an instance of LoggingFinalizer and attach it
12            LoggingFinalizer f = new LoggingFinalizer();
13            System.attachFinalizer(f);
14
15            // While executing the job, log using LoggingFinalizer.addLog()
16            // Note that addlog() modifies the Finalizer's state after it is attached 
17            DateTime start = DateTime.now();
18            f.addLog('About to do some work...', jobId);
19
20            while (true) {
21              // Results in limit error
22            }
23        } catch (Exception e) {
24            System.debug('Error executing the job [' + jobId + ']: ' + e.getMessage());
25        } finally {
26            System.debug('Completed: execution of queueable job: ' + jobId);
27        }
28    }
29
30  // Finalizer implementation
31  // Logging finalizer provides a public method addLog(message,source) that allows buffering log lines from the Queueable job.
32  // When the Queueable job completes, regardless of success or failure, the LoggingFinalizer instance commits this buffered log.
33  // Custom object LogMessage__c has four custom fields-see addLog() method.
34
35    // internal log buffer
36    private List<LogMessage__c> logRecords = new List<LogMessage__c>();
37
38    public void execute(FinalizerContext ctx) {
39        String parentJobId = '' + ctx.getAsyncApexJobId();
40        System.debug('Begin: executing finalizer attached to queueable job: ' + parentJobId);
41
42        // Update the log records with the parent queueable job id
43        System.Debug('Updating job id on ' + logRecords.size() + ' log records');
44        for (LogMessage__c log : logRecords) {
45            log.Request__c = parentJobId; // or could be ctx.getRequestId()
46        }
47        // Commit the buffer
48        System.Debug('committing log records to database');
49        Database.insert(logRecords, false);
50
51        if (ctx.getResult() == ParentJobResult.SUCCESS) {
52            System.debug('Parent queueable job [' + parentJobId + '] completed successfully.');
53        } else {
54            System.debug('Parent queueable job [' + parentJobId + '] failed due to unhandled exception: ' + ctx.getException().getMessage());
55            System.debug('Enqueueing another instance of the queueable...');
56        }
57        System.debug('Completed: execution of finalizer attached to queueable job: ' + parentJobId);
58    }
59
60    public void addLog(String message, String source) {
61        // append the log message to the buffer
62        logRecords.add(new LogMessage__c(
63            DateTime__c = DateTime.now(),
64            Message__c = message,
65            Request__c = 'setbeforecommit',
66            Source__c = source
67        ));
68    }
69}

1public class RetryLimitDemo implements Finalizer, Queueable {
2
3  // Queueable implementation
4  public void execute(QueueableContext ctx) {
5    String jobId = '' + ctx.getJobId();
6    System.debug('Begin: executing queueable job: ' + jobId);
7    try {
8        Finalizer finalizer = new RetryLimitDemo();
9        System.attachFinalizer(finalizer);
10        System.debug('Attached finalizer');
11        Integer accountNumber = 1;
12        while (true) { // results in limit error
13          Account a = new Account();
14          a.Name = 'Account-Number-' + accountNumber;
15          insert a;
16          accountNumber++;
17        }
18    } catch (Exception e) {
19        System.debug('Error executing the job [' + jobId + ']: ' + e.getMessage());
20    } finally {
21        System.debug('Completed: execution of queueable job: ' + jobId);
22    }
23  }
24
25  // Finalizer implementation
26  public void execute(FinalizerContext ctx) {
27    String parentJobId = '' + ctx.getAsyncApexJobId();
28    System.debug('Begin: executing finalizer attached to queueable job: ' + parentJobId);
29    if (ctx.getResult() == ParentJobResult.SUCCESS) {
30        System.debug('Parent queueable job [' + parentJobId + '] completed successfully.');
31    } else {
32        System.debug('Parent queueable job [' + parentJobId + '] failed due to unhandled exception: ' + ctx.getException().getMessage());
33        System.debug('Enqueueing another instance of the queueable...');
34        String newJobId = '' + System.enqueueJob(new RetryLimitDemo()); // This call fails after 5 times when it hits the chaining limit
35        System.debug('Enqueued new job: ' + newJobId);
36    }
37    System.debug('Completed: execution of finalizer attached to queueable job: ' + parentJobId);
38  }
39}