我有一个类在vert.x event bus
上发送消息,然后处理来自事件总线消费者的回复。当类运行时,它会调用在构造函数或特定方法调用中传递给它的对象上的方法。
为了验证传入的对象上的方法确实被调用,使用Mockito模拟对象。以下是测试类的基本结构:
@RunWith(VertxUnitRunner.class)
public class MyTest {
@Rule
public RunTestOnContext rule = new RunTestOnContext(new VertxOptions());
@Test
public void test(TestContext context) {
Runnable r = new Runnable() {
@Override
public void run() {
// Create an event bus consumer for testing
// ...
// Create the class to be tested
Dao dao = new Dao();
DbManager dbManager = Mockito.mock(DbManager.class);
dao.save(dbManager);
}
}
Thread t2 = new Thread(r);
t2.start();
t2.join();
Mockito.verify(dbManager, ...
async.complete();
}
}
这只在某些时候有效。问题是,当dao
类向vert.x event bus
发送异步消息并处理响应时,这一切都发生在与join()
调用正在等待的不同的线程中,因此Mockito.verify
可能发生在线程之前vertx管理已完成。
构建这些测试的最佳方法是什么,以便Mockito将等到所有依赖异步线程完成?
谢谢
我想到的唯一一件事是用超时验证,这意味着mockito会等待一段指定的时间进行交互而不是立即失败。
Mockito.verify(dbManager, Mockito.timeout(5000)).....