我们有一些集成测试，结果是在同一个目的地上调度了许多消息，但是有许多不同的组。
spring.cloud.stream.bindings.userEdited-out-0.destination=user.exchange
spring.cloud.stream.rabbit.bindings.userEdited-out-0.producer.routing-key-expression='user-edited.v1'
spring.cloud.stream.bindings.userEdited-out-0.content-type=application/json
spring.cloud.stream.bindings.userCreated-out-0.destination=user.exchange
spring.cloud.stream.rabbit.bindings.userCreated-out-0.producer.routing-key-expression='user-created.v1'
spring.cloud.stream.bindings.userCreated-out-0.content-type=application/json我已经成功地使用OutputDestination读取了这些消息，但是似乎我只能提取发送到目的地（exchange）的消息，并且还不能按发送到的组（主题）进行过滤。
有没有办法按目标和组从OutputDestination提取消息？
1条答案
按热度按时间cgfeq70w1#
这是正确的，并且是设计的，因为分组是特定于绑定器实现（即，rabbit）的，或者是代理的本地功能的一部分（kafka）。因此，测试绑定器的设计是为了确保接收和发送消息所涉及的所有核心组件都得到测试。