如何使用 OutputDestination 捕获特定于组的消息?

How to capture group specific messages with OutputDestination?

我们进行了集成测试,最终会在同一目的地但在许多不同的组上分派许多消息。在 rabbitMQ 术语中,相同的交换与不同的主题。

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 读取了这些消息,但似乎我只能提取发送到目的地(交换)的消息,并且无法按组(主题)进行过滤发送至.

有什么方法可以按目的地和组从 OutputDestination 拉取消息吗?

这是正确的并且是设计使然,因为分组特定于活页夹实现(即 rabbit)或代理(kafka)的本机功能的一部分。 所以test binder就是为了保证所有涉及到接收和发送消息的核心组件都经过测试