1 files changed, 13 insertions, 0 deletions
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