テストイベントメッセージの配信

1// Create test events
2Test.startTest();
3// Publish test events with EventBus.publish()
4Test.stopTest();
5// Perform validations

1Test.startTest();
2// Create test events
3// ...
4// Publish test events with EventBus.publish()
5// ...
6// Deliver test events
7Test.getEventBus().deliver();
8// Perform validations 
9// ...
10Test.stopTest();

1Test.startTest();
2// Do some tests
3Test.stopTest();
4
5// Deliver test events
6Test.getEventBus().deliver();

1try {
2    Test.startTest();
3    Database.executeBatch(new SampleBatchApex());
4    Test.stopTest();
5    // Batch Apex job executes here
6} catch(Exception e) {
7    // Catch any exceptions thrown in the batch job
8}
9
10// The batch job fires BatchApexErrorEvent if it fails, so deliver the event.
11Test.getEventBus().deliver();

1Test.startTest();
2System.enqueueJob(new SampleQueueableApex());
3Test.stopTest();
4// Queueable Apex job executes here.
5// The platform event message published by the job is delivered too.

1@isTest
2public class MyTestClassDeliver {
3
4    @isTest static void doSomeTesting() {
5
6        Test.startTest();
7        
8        // Publish a test event
9        Order_Event__e event = new Order_Event__e(
10              Event_ID__c='123AB', Order_Number__c='12346', Has_Shipped__c=true);
11        Database.SaveResult sr = EventBus.publish(event);   
12
13        // Verify that the publish was successful
14        System.assertEquals(true, sr.isSuccess());
15        
16        // Deliver the test event before Test.stopTest()
17        Test.getEventBus().deliver();        
18        
19        // Check that the case that the trigger created is present.
20        List<Task> tasks = [SELECT Id FROM Task];
21        // Validate that this task was found.
22        // There is only one test task in test context.
23        Integer taskCount = tasks.size();
24        System.assertEquals(1, taskCount);
25        
26        // Publish a duplicate event
27        Order_Event__e dupEvent = new Order_Event__e(
28              Event_ID__c='123AB', Order_Number__c='12346', Has_Shipped__c=true);
29        Database.SaveResult sr2 = EventBus.publish(dupEvent);
30
31        // Verify that the publish was successful.
32        System.assertEquals(true, sr2.isSuccess());
33
34        Test.getEventBus().deliver();        
35        
36        // Get all tasks in test context
37        List<Task> tasksNew = [SELECT Id FROM Task];
38        // Validate that no task was created and 
39        // the number of tasks should not have changed.
40        System.assertEquals(taskCount, tasksNew.size());
41        
42        Test.stopTest();    
43
44    }
45}

1trigger OrderTrigger on Order_Event__e (after insert) {
2    // List to hold all cases to be created.
3    List<Task> tasks = new List<Task>();
4    
5    // Get user Id for case owner
6    User usr = [SELECT Id FROM User WHERE Name='<Replace with FirstName LastName>' LIMIT 1];    
7    
8    // Iterate through each notification.
9    for (Order_Event__e event : Trigger.New) {
10        if (event.Has_Shipped__c == true) {
11            // Create task only if it doesn't exist yet for the same order 
12            String eventID = '%' + event.Event_ID__c;
13            List<Task> tasksFromQuery = 
14                [SELECT Id FROM Task WHERE Subject LIKE :eventID];
15            if (tasksFromQuery.size() == 0) {
16                Task t = new Task();
17                t.Priority = 'Medium';
18                t.Subject = 'Follow up on shipped order ' + event.Order_Number__c + 
19                    ' for event ID ' + event.Event_ID__c;
20                t.OwnerId = usr.Id;
21                tasks.add(t);
22            }
23        }
24    }
25    // Insert all tasks in the list.
26    if (tasks.size() > 0) {
27        insert tasks;
28    }
29
30}

1@isTest
2public class MyCallbackTest {
3    @isTest static void testFailedEventsWithFail() {
4        
5        // Publish with callback
6        FailureAndSuccessCallback cb = new FailureAndSuccessCallback();
7
8        // Create test event with EventUuid field value
9        Order_Event__e event = (Order_Event__e)Order_Event__e.sObjectType.newSObject(null, true);
10        event.Order_Number__c='100';
11        System.debug('EventUuid of created event: ' + event.EventUuid);
12        // Publish an event with callback
13        EventBus.publish(event, cb);
14
15        // Fail event 
16        // (invoke onFailure and DO NOT deliver event to subscribers)
17        Test.getEventBus().fail(); 
18        
19        // Verify that tasks were created by the onFailure() method
20        List<Task> tasksFailed = 
21            [SELECT Id,Subject,Description FROM Task 
22             WHERE Subject='Follow up on event publishing failures.'];
23        System.Assert.areEqual(1,tasksFailed.size(),
24                            'Unexpected number of tasks received for failed publishing');
25        System.debug('tasksFailed[0].Description=' + tasksFailed[0].Description);
26        System.debug('event.EventUuid=' + event.EventUuid);
27        System.Assert.isTrue(tasksFailed[0].Description.contains(event.EventUuid),
28                            'EventUuid was not found in the Description field.');
29
30    }
31}