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());
    }
}