Spring 集成 : testing poller dependent logic

Question

我想知道如何编写 Spring 测试来断言由“SourcePollingChannelAdapter”触发的逻辑链。

我想到了什么:

• 使用 Thread.sleep() 这对测试来说真的很糟糕
• 有另一个测试版本的 spring 上下文，我将用直接 channel 替换所有可轮询 channel 。这需要很多工作。

有没有什么通用的方法可以在测试中强制触发轮询器？

Answer 1

通常我们在测试中使用 QueueChannel 并通过其 receive(10000) 方法等待消息。这样，独立于数据源，我们的测试方法线程将被阻塞，直到数据到达。

SourcePollingChannelAdapter 由TaskScheduler 触发，因此整个流程逻辑在与测试方法不同的线程中完成。我的意思是，您关于更换 channel 的想法无济于事。 Thread.sleep() 可能有值(value)，但 QueueChannel.receive(10000) 更可靠，因为我们实际上只等待那 10 秒。

另一种阻止测试用例的方法来自标准 CountDownLatch，您可以在流程中的某处countDown() 并在测试方法中等待它。

还有一些其他的测试方法:在迭代之间有一些 sleep 周期较短的循环，并检查一些条件以退出并验证。最后，这在轮询器和数据库的情况下可能很有用。因此，我们将在该循环中执行 SELECT 直到达到所需状态。

您可以在 Reference Manual 中找到一些附加信息.