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

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

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

diff --git a/jws/kafka/src/main/java/fr/epita/assistants/StringInfoResource.java b/jws/kafka/src/main/java/fr/epita/assistants/StringInfoResource.java
new file mode 100644
index 0000000..62a5d51
--- /dev/null
+++ b/jws/kafka/src/main/java/fr/epita/assistants/StringInfoResource.java
@@ -0,0 +1,25 @@
+package fr.epita.assistants;
+
+import io.smallrye.reactive.messaging.annotations.Broadcast;
+import jakarta.inject.Inject;
+import jakarta.ws.rs.Consumes;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.Path;
+import org.eclipse.microprofile.reactive.messaging.Channel;
+import org.eclipse.microprofile.reactive.messaging.Emitter;
+
+import java.util.concurrent.CompletionStage;
+
+@Path("/send")
+@Consumes
+public class StringInfoResource {
+    @Inject
+    @Broadcast
+    @Channel("string-info-command")
+    Emitter<String> commandEmitter;
+
+    @POST
+    public void send(String s) {
+        CompletionStage<Void> v = commandEmitter.send(s);
+    }
+}
\ No newline at end of file
-- 
cgit v1.2.3