jws/kafka/src/main/java/fr/epita/assistants/StringInfoResource.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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);
    }
}