我在关注quarkusReact消息传递我想用一个非常简单的随机生成器生成一个kafka主题，每5秒生成一个，但我希望它在特定条件下阻塞。例如，我将如何修改下面的函数，使其仍然根据rest调用的结果每5秒尝试生成一次？我知道我可以有一个函数，使用一个发射器调用 .send(message) 只有当我收到rest调用的响应代码，但我不确定我是否可以用multi欺骗它？

@Outgoing("generated-price")                        
    public Multi<Integer> generate() {                  
        return Multi.createFrom().ticks().every(Duration.ofSeconds(5))
                .onOverflow().drop()
                .map(tick -> random.nextInt(100));
    }