如何解决用于 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 举报,一经查实,本站将立刻删除。