我使用的是Spring集成和junit。
@Test
public void testOnePojo() throws Exception {
ExecutorChannel orderSendChannel =
context.getBean("validationChannel", ExecutorChannel.class);
ExecutorChannel orderReceiveChannel = context.getBean("auditChannel", ExecutorChannel.class);
orderReceiveChannel.subscribe(t -> {
System.out.println(t);//I want to see this output
});
orderSendChannel.send(getMessageMessage());
}
我看不到接收通道的输出。JUnit在订阅后退出。它有一个合适的方法在testOnePojo
内等待,直到auditChannel
收到响应。
1条答案
按热度按时间jvlzgdj91#
您可以在测试中使用CoundDownLatch并等待MessageHandler处理您的消息。您的示例如下所示: