我有两个用Kotlin Vert.x编写的Hello World句柄方法。我想清楚地了解他们是如何工作的,如果可能的话。一个是AsyncVertilce,另一个是CompositeVerticle。getDependentAddress(HELLO_WORLD), message.headers(), message.body(), messageMarker)
val result = CompositeFuture.all
//I need to incorporate the logic here that adds futures to list and composes the compositefutureWhat goes as first and second argument of executeBlocking method
/*CompositeFuture.join(futureList)我试图避免将Springboot和Vertx混为一谈,但遗憾的是,Vertx CompositeFuture在这里没有工
我有四个I/O操作:A、B、C和D。它们中的每一个都应该使用vertx.executeBlocking执行。我应该有下一个行为:waitForExecuteBlocking(A_OPERATION);/* do something */我在里找不到溶质。我不想把我的*_OPERATION类包装成员工眩晕的原因是有原因的。
我使用for循环中的vertx中的executeBlocking并行处理结果,并使用CompositeFuture对结果进行排序。基于所有的结果,我想从方法中返回一些值,但是CompositeFuture处理程序中的lambda函数不允许我这样做。如何使用这个用例?LOGGER.error("Task FAILED for service {}", service, asyncResult.cause()); });
Compos