@@ -423,11 +423,11 @@ class ExternalizationConfiguration {
423
423
@Bean
424
424
EventExternalizationConfiguration eventExternalizationConfiguration() {
425
425
426
- return EventExternalizationConfiguration.externalizing() // <1>
427
- .select(EventExternalizationConfiguration.annotatedAsExternalized()) // <2>
428
- .mapping(SomeEvent.class, it -> …) // <3>
429
- .routeKey(WithKeyProperty.class, WithKeyProperty::getKey) // <4>
430
- .build();
426
+ return EventExternalizationConfiguration.externalizing() // <1>
427
+ .select(EventExternalizationConfiguration.annotatedAsExternalized()) // <2>
428
+ .mapping(SomeEvent.class, it -> …) // <3>
429
+ .routeKey(WithKeyProperty.class, WithKeyProperty::getKey) // <4>
430
+ .build();
431
431
}
432
432
}
433
433
----
@@ -441,11 +441,11 @@ class ExternalizationConfiguration {
441
441
@Bean
442
442
fun eventExternalizationConfiguration(): EventExternalizationConfiguration {
443
443
444
- EventExternalizationConfiguration.externalizing() // <1>
445
- .select(EventExternalizationConfiguration.annotatedAsExternalized()) // <2>
446
- .mapping(SomeEvent::class, it -> …) // <3>
447
- .routeKey(WithKeyProperty::class, WithKeyProperty::getKey) // <4>
448
- .build()
444
+ EventExternalizationConfiguration.externalizing() // <1>
445
+ .select(EventExternalizationConfiguration.annotatedAsExternalized()) // <2>
446
+ .mapping(SomeEvent::class, it -> …) // <3>
447
+ .routeKey(WithKeyProperty::class, WithKeyProperty::getKey) // <4>
448
+ .build()
449
449
}
450
450
}
451
451
----
@@ -503,6 +503,7 @@ class OrderIntegrationTests {
503
503
// …
504
504
var matchingMapped = events.ofType(OrderCompleted::class)
505
505
.matching(OrderCompleted::getOrderId, reference.getId())
506
+
506
507
assertThat(matchingMapped).hasSize(1)
507
508
}
508
509
}
0 commit comments