From e659b2fbfd9e93e51b2b51bbb5dfe27bacc25662 Mon Sep 17 00:00:00 2001
From: emanueltrandafir1993 <emanueltrandafir1993@gmail.com>
Date: Wed, 7 Feb 2024 23:00:56 +0100
Subject: [PATCH] BAEL-7523: small changes

---
 .../EventExternalizationConfig.java           | 19 ++++++++++++++-----
 .../WeeklySummaryPublishedEvent.java          |  7 +++++++
 2 files changed, 21 insertions(+), 5 deletions(-)
 create mode 100644 spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/WeeklySummaryPublishedEvent.java

diff --git a/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/EventExternalizationConfig.java b/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/EventExternalizationConfig.java
index 9564696d92..ee508fb261 100644
--- a/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/EventExternalizationConfig.java
+++ b/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/EventExternalizationConfig.java
@@ -8,6 +8,7 @@ import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.core.ProducerFactory;
 import org.springframework.kafka.core.KafkaOperations;
 import org.springframework.modulith.events.EventExternalizationConfiguration;
+import org.springframework.modulith.events.Externalized;
 import org.springframework.modulith.events.RoutingTarget;
 
 @Configuration
@@ -23,19 +24,27 @@ class EventExternalizationConfig {
           )
           .mapping(
             ArticlePublishedEvent.class,
-            it -> new ArticlePublishedKafkaEvent(it.slug(), it.title())
+            it -> new PostPublishedKafkaEvent(it.slug(), it.title())
+          )
+          .route(
+            WeeklySummaryPublishedEvent.class,
+            it -> RoutingTarget.forTarget("baeldung.articles.published").andKey(it.handle())
+          )
+          .mapping(
+            WeeklySummaryPublishedEvent.class,
+            it -> new PostPublishedKafkaEvent(it.handle(), it.heading())
           )
           .build();
     }
 
-    record ArticlePublishedKafkaEvent(String slug, String title) {
-    }
-
-
     @Bean
     KafkaOperations<String, ArticlePublishedEvent> kafkaOperations(KafkaProperties kafkaProperties) {
         ProducerFactory<String, ArticlePublishedEvent> producerFactory = new DefaultKafkaProducerFactory<>(kafkaProperties.buildProducerProperties());
         return new KafkaTemplate<>(producerFactory);
     }
+
+    record PostPublishedKafkaEvent(String slug, String title) {
+    }
+
 }
 
diff --git a/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/WeeklySummaryPublishedEvent.java b/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/WeeklySummaryPublishedEvent.java
new file mode 100644
index 0000000000..2ae8713099
--- /dev/null
+++ b/spring-boot-modules/spring-boot-libraries-3/src/main/java/com/baeldung/springmodulith/events/externalization/WeeklySummaryPublishedEvent.java
@@ -0,0 +1,7 @@
+package com.baeldung.springmodulith.events.externalization;
+
+import org.springframework.modulith.events.Externalized;
+
+@Externalized
+record WeeklySummaryPublishedEvent(String handle, String heading) {
+}
\ No newline at end of file