java - 经纪人确认 Micronaut 2.2.1 中的 Rabbit MQ 没有工作

Question

我正在尝试在 Micronaut 中使用 RabbitMQ 获得代理确认。

听众

@RabbitListener
public class ProductListener {

    @Queue(ProductTopicConstants.GET_PRODUCTS)
    public String find(String text) {
        return text.toUpperCase();
    }
}

控制器

@Get(value = "/{text}", single = true)
    public Maybe<String> Find(String text) {
        iproductProducer.find(text).subscribe(item ->{
            System.out.println(item);
        });
        return null;
    }

制片人

@RabbitClient(ProductTopicConstants.FETE_BIRD_EXCHANGE)
public interface IProductProducer {
    @Binding(ProductTopicConstants.GET_PRODUCTS)
    Maybe<String> find(String text);
}

更新 - #1

@RabbitClient(ProductTopicConstants.FETE_BIRD_EXCHANGE)
    public interface IProductProducer {
        @Binding(ProductTopicConstants.GET_PRODUCTS)
        Completable find(String text);
    }

根据文档

客户端方法支持两种返回类型，void 和反应类型。如果该方法返回 void，则消息将被发布并且该方法将在没有确认的情况下返回。如果响应类型是返回类型，则将返回一个可以订阅的“冷”发布者。

但是在控制器System.out.println(item);中，确认永远不会得到。

Answer 1

您不是在寻找经纪人的认可。您正在描述 RPC。文档清楚地说明了如何设置它。据我所知，您似乎缺少@RabbitProperty(name = "replyTo", value = "amq.rabbitmq.reply-to")客户端。