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


1
2
3
4
5
6
7
8
9
10
11
12
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());
    }
}