Platform Events Developer Guide
j
No Results
Search Tips:
- Please consider misspellings
- Try different search keywords
Test Retried Event Messages
To force redelivery of a retried event message in an Apex test, call Test.EventBus.deliver(). This method also delivers other event messages that have been published after the last deliver() call.
In API version 43.0 or later, you can check these new EventBusSubscriber fields to test retried triggers.
- Retries
- LastError
The EventBusSubscriber.Retries field indicates how many times a trigger was retried.
EventBusSubscriber.LastError indicates the error message that was passed to the throw statement that executed last (throw new EventBus.RetryableException('Error Message')).
Example
This test method delivers a test event message that fires a trigger. The associated event trigger throws EventBus.RetryableException twice. The test verifies that the trigger was retried twice by querying EventBusSubscriber and checking the Retries field value.
Before you can run this test class, define a platform event with the name of Order_Event__e and the following fields: Order_Number__c of type Text and Has_Shipped__c of type Checkbox. This test class assumes there is an associated trigger called OrderTriggerRetry that retries the event. The trigger is not provided in this example.
@isTest
public class MyTestClassRetryDoc {
@isTest static void doSomeTesting() {
Test.startTest();
// Publish a test event
Order_Event__e event = new Order_Event__e(
Order_Number__c='12345', Has_Shipped__c=true);
Database.SaveResult sr = EventBus.publish(event);
// Deliver the initial event message.
// This will fire the associated event trigger.
Test.getEventBus().deliver();
// Trigger retries event twice, so loop twice
for(Integer i=0;i<2;i++) {
// Get info about all subscribers to the event
EventBusSubscriber[] subscribers =
[SELECT Name, Type, Position, Retries, LastError
FROM EventBusSubscriber WHERE Topic='Order_Event__e'];
for (EventBusSubscriber sub : subscribers) {
System.debug('sub.Retries=' + sub.Retries);
System.debug('sub.lastError=' + sub.lastError);
if (sub.Name == 'OrderTriggerRetry') {
System.assertEquals(i+1, sub.Retries);
}
}
// Deliver the retried event
Test.getEventBus().deliver();
}
Test.stopTest();
}
}