对于汇总弹簧云流应用单元测试

Question

对于汇总弹簧云流应用单元测试之后我的主要方法如下：

@SpringBootApplication 
public class MyApplication { 
    public static void main(String[] args) { 
     new AggregateApplicationBuilder(MyApplication .class, args) 
       .from(MyProcessor.class) 
       .via(MyFilterProcessor.class) 
       .run(); 
    } 
} 

在单元测试中，我通过处理器发送消息像下面那样，但是只有MyProcessor被调用。如果我通过数据流服务器部署这个聚合应用程序，一切都按预期工作。

请告知

@RunWith(SpringJUnit4ClassRunner.class) 
    @SpringBootTest(classes = { 
        MyApplication .class, 
       }) 
    @DirtiesContext 
    public class AggTest{ 
    @Autowired 
    private Processor processor; 

    @Autowired 
    protected MessageCollector messageCollector; 

    @Test 
     public void testMethod(){ 
     processor.input().send(message); 
     messageCollector.forChannel(processor.output()).poll(); 
    } 
    } 

Answer 1

我添加https://github.com/spring-cloud/spring-cloud-stream/issues/723跟踪此。

被测试的应用程序需要设置为聚合 - 与main方法一样。但是，在这种情况下，查看输入通道并发送消息似乎并不容易。恐怕这是一个阻碍，但希望我们很快就会解决它。