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

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}