java如何对基于消息的处理执行集成测试？

11 月，1 周 Questions & Answers 34

假设我正在使用pubsub或其他消息服务。当接收到消息时，执行一些处理并将结果写入数据库

现在在我的集成测试中，我将启动一个pubsub模拟器并发送一条消息。现在我想验证是否调用了处理方法，以及数据库中的结果是否正确。如果处理发生了，那也没问题。现在这可能需要一段时间。我唯一想到的是发出消息，然后执行await().atMost(5, TimeUnit.SECONDS).until(() -> {...repository.find...}