有人能给我解释一下这两种方法的区别吗： ..........vertx.evenbus().send("test", res->{});public void test(Handler<AsyncResult<JsonObject>> resultHandler){
浏览 8提问于2016-09-22得票数 0
回答已采纳
"io.vertx:vertx-lang-groovy:3.8.1" 我想使用vert.xjvm在单个EventBus应用程序中实现反应式代码(没有Verticle)。我已经验证了出站拦截器和SharedData是否正常工作。但是，没有任何入站拦截器或使用者被调用的迹象。().consumer("abc", msg -> {
log.debug("abc handler 2
浏览 82提问于2019-10-07得票数 0
回答已采纳
2回答
我有一个发送者和一个消费者来交换消息：@Override eventBus.send(Constants.ADDRESS, "Hello from sender", res -class Consumer extends Abstr
浏览 3提问于2018-03-23得票数 3
1回答
我有两个java类使用vert.x EventBus进行通信。我有一个Productor.java类：import io.vertx.core.eventbus.EventBus; }和一个Consumer.java类：
import io.vertx.core.
浏览 4提问于2020-02-28得票数 0
回答已采纳
1回答
我使用的是vert.x 2.1.5版本。我试图在我的项目中使用事件循环。int x = jsonObject1.getInteger("X"); //calling another event //it will create one json object with prop
浏览 0提问于2016-07-21得票数 2
所以这有点偷偷摸摸的，它不是100%发生的，但情况是这样的： this.vertx.eventBus().consumer("bla", event ->public void start() throws Except
浏览 0提问于2017-01-09得票数 1
回答已采纳
()) {
testContext.completeNow() }如果Verticle的start()方法是以"common“的方式编写的，那么测试是肯定通过的
浏览 14提问于2020-02-13得票数 0
我是vertx的新手，为了更好地了解Vertx，我尝试了一些东西。我已经写了一个应用程序，需要一些帮助来部署相同的多个实例，我已经粘贴了下面的代码，任何人可以让我知道这是正确的和正确的方式。import io.vertx.core.AbstractVerticle;import io.vertx.core.eventbus.Even
浏览 1提问于2016-07-24得票数 0
1回答
eb.consumer(FIND_USER_SERVER).handler(message -> { message.reply(getResult(res)); });
我的问题是:如何从事件总线获取用户？就像我在routingContext上做的那样？
浏览 3提问于2015-10-05得票数 0
我使用EventBus发送消息，我希望将回复消息放入一个变量中，然后将返回it.this是代码块。final Logger logger = LoggerFactory.getLogger(MessageExecute.class);
<e
浏览 4提问于2016-03-28得票数 2
, pricemessage, reply -> {
}public void start() {}
vertx.eventBus().consumer(ADDRESSH
浏览 1提问于2016-09-19得票数 1
从我的具有路由URL的路由垂直节点，我想将RoutingContext对象发送到另一个垂直节点。我相信我们只能使用vertx.eventBus().send()将消息从路由垂直节点发送到其他操作垂直节点。是否可以将RoutingContext对象作为消息发送？在路由器纵向测试中，我正在执行vertx.eventBus().<RoutingContext>send("address", routingContext)
在消费者领域，我正在做
浏览 17提问于2019-08-16得票数 0
我正在尝试使用redis pubsub顶点，如下所示，但我一直在使用
vertx.eventBus<JsonObject>consumer(VERTX_EVENTBUS_PREFIX + ASYNC_RESPONSE_CHANNEL, message -> {
log.debug("Vertxevent bu
浏览 4提问于2016-08-11得票数 0
回答已采纳
我只是在使用vert.x 3.5.3 Kotlin，我无法使用gson将JSON字符串解析为数据类。= vertx.eventBus() when (it.headers().get("ACTIONelse -> { } }
浏览 19提问于2019-03-06得票数 1
回答已采纳
我正在创建一个在服务器上运行的应用程序集群。在java中，我将Hazelcast-cluster与VertX结合使用。现在，我想将vertx eventbus扩展为在同一服务器上运行的NodeJs应用程序。Hazelcast正在节点中运行，并与在JVM上运行的hazelcast成员正确连接
var HazelcastClient = require('hazelcast-client').Client;then(function (hazelcast
浏览 1提问于2017-05-11得票数 2
我对Vert.x3还不熟悉，我正试图为一个简单的事件处理程序编写一个单元测试。现在，我所要做的就是检查测试中的垂直线是否委托给正确的组件，该组件是使用Mockito作为模拟创建的。void setUp(TestContext context) { //verticle is set up with mockcontext) {
EventBus</
浏览 0提问于2016-09-21得票数 2
我正在创建一个消息使用者，并将其附加到vertx事件总线上的一个地址上。在稍后的程序中，我将取消该用户的注册。我如何知道消费者是否未成功注册？下面的代码片段显示了如何在顶点事件总线上的地址上注册使用者
MessageConsumer<JsonObject> consumer = vertx.eventBus().consumer("my_channel", event
浏览 34提问于2022-03-28得票数 1
回答已采纳
我有一个带有两个端点的got服务器，我想在不同的机器上处理这些端点。它们是独立的，在更新其中一个时，我不想重新启动另一个。Router router = Router.router(vertx); router.post我一直在阅读关于的文章，但我不太清楚如何将它应用于路由器。
浏览 2提问于2017-09-25得票数 1
回答已采纳
我对发布-订阅模式很陌生，我们在应用程序中使用了Vertx。我尝试这样做是为了一些用例，我在它自己的消费者内部发布： EventBus eb = Vertx.currentContext().owner().eventBus();
MessageConsumer<String> consumer = eb.consumer("myAddress"
浏览 32提问于2020-06-08得票数 1
回答已采纳
下面的代码在事件总线上放置消息Single<Message<Integer>> reply = rxVertx.eventBus().：});
要返回的值来自使用</
浏览 0提问于2019-08-01得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
