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