From 967be9e750221ab2ab783f95df79bb26d290a45e Mon Sep 17 00:00:00 2001
From: Martial Simon <msimon_fr@hotmail.com>
Date: Mon, 15 Sep 2025 01:07:58 +0200
Subject: add: added projects

---
 .../main/java/fr/epita/assistants/StringInfoSubscriber.java | 13 +++++++++++++
 1 file changed, 13 insertions(+)
 create mode 100644 jws/kafka/src/main/java/fr/epita/assistants/StringInfoSubscriber.java

(limited to 'jws/kafka/src/main/java/fr/epita/assistants/StringInfoSubscriber.java')

diff --git a/jws/kafka/src/main/java/fr/epita/assistants/StringInfoSubscriber.java b/jws/kafka/src/main/java/fr/epita/assistants/StringInfoSubscriber.java
new file mode 100644
index 0000000..c955270
--- /dev/null
+++ b/jws/kafka/src/main/java/fr/epita/assistants/StringInfoSubscriber.java
@@ -0,0 +1,13 @@
+package fr.epita.assistants;
+
+import fr.epita.assistants.utils.StringInfo;
+import io.smallrye.reactive.messaging.annotations.Broadcast;
+import org.eclipse.microprofile.reactive.messaging.Incoming;
+
+public class StringInfoSubscriber {
+    @Incoming("string-info-aggregate")
+    @Broadcast
+    public void subscribe(StringInfo si) {
+        System.out.println(si.toString());
+    }
+}
\ No newline at end of file
-- 
cgit v1.2.3