spring-cloud-stream - 如何在不使用 Transformer 的情况下获取 TestSupportBinder 中的 channel

Question

我正在尝试使用 TestSupportBinder 为 Spring Cloud Stream 应用程序编写测试。我找到的所有示例，包括 official documents和 official github ，是用 Transformer 测试 Processor。这些测试使用 Tranformer 获取输出 Channel，并将 Channel 对象提供给 messageCollector.forChannel 方法来轮询输出。

但是，我没有使用提供的处理器，而是编写了自己的接口(interface)。我找不到在测试代码中获取所需 Channel 对象的方法。我曾尝试将我的接口(interface) Autowiring 到测试类中以获取 Channel 对象，但以 java.lang.IllegalArgumentException: Channel [MY_CHANNEL] was not bond by class org.springframework.cloud.stream.test.binder.TestSupportBinder.

Answer 1

该错误消息表示 channel MY_CHANNEL 未注册到 MessageCollector。并且，这表明您的接口(interface) channel MY_CHANNEL 未在您的应用程序中使用 EnableBinding 进行声明。您的应用程序中是否有 @EnableBinding(MyOwnInterface.class)(MyOwnInterface 声明 MY_CHANNEL channel )？