用于 consumerBatchEnabled 侦听器的 Rabbitmq 单元测试

问题描述

我正在点击下面的链接为兔子编写 Junit：

RabbitListenerTestHarness injects actual objects in listeners

唯一的变化是我分批消费事件：

我的消费者定义如下：

public class MyListener {

    @Autowired
    private SomeService service;

    @RabbitListener(id = "myListener",queues = "foo")
    public void listen(List<Messge<Foo>> foo) {
        this.service.process(foo);
    }
}

问题是当我运行 Junit 测试时，在 rabbitlistener 中我期待的是 List<Message<Foo>> 而我实际上得到的是 List<Foo>。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）