emitter.java

@ApplicationScoped
@Slf4j
public class EmitterService
{
    @Inject
    @Channel("out-topic")
    Emitter<String> sender;

    // Create an event and put it on a queue
    public void createEvent(String message)
    {
        log.info("Sending event: {}", message);
        this.sender.send(message);
    }
}