腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9295)
视频
沙龙
1
回答
eventBus
().
consumer
()从
不被
调用
spring-boot
、
vert.x
、
vertx-eventbus
但是,没有任何入站拦截器或使用者被
调用
的迹象。 我怀疑我在配置vert.x时忽略了什么,或者在Spring Boot中嵌入vert.x以某种方式阻止了入站消息的接收。vertx.
eventBus
().().
consumer
("abc", msg -> { }); vertx.
eventBus
= vertx.
eventBus
().
consum
浏览 82
提问于2019-10-07
得票数 0
回答已采纳
2
回答
Vertx:消息回复超时
vert.x
eventBus
= vertx.
eventBus
(); System.out.println("Failed to send reply." + res.cause()); });
eventBus
.
consumer
class
Consumer</
浏览 3
提问于2018-03-23
得票数 3
1
回答
Java - Vertx -Publish-Subscribe模式:在自己的消费者内部发布消息。这是个坏主意吗?
java
、
asynchronous
、
functional-programming
、
publish-subscribe
、
vert.x
我尝试这样做是为了一些用例,我在它自己的消费者内部发布:
EventBus
eb = Vertx.currentContext().owner().
eventBus
();
consumer
.handler这是否也会导致StackOverFlow错误,如递归
调用<
浏览 32
提问于2020-06-08
得票数 1
回答已采纳
1
回答
event_bus使用者是否支持运行异步。方法?
vert.x
、
vertx-eventbus
我有event_bus使用者,一旦收到消息,就需要
调用
异步。方法async_method_to_access_database
从
数据库获取数据库记录。
EventBus
eb = vertx.
eventBus
();
consumer
.handler
浏览 6
提问于2022-04-13
得票数 1
回答已采纳
1
回答
终止事件总线并获得结果
java
、
rx-java
、
vert.x
并将它们发布到事件总线,例如,
从
REST读取名称,
从
文件系统读取名称:/** .map(Buffer::toString) .subscribe(c -> vertx.
eventBus
extends AbstractVerticle { public voi
浏览 3
提问于2017-04-24
得票数 1
回答已采纳
1
回答
quarkus-vertx:来自verticle的非阻塞数据库
调用
导致ContextNotActiveException
asynchronous
、
spring-data-jpa
、
vert.x
、
quarkus
我通过Vert.x
EventBus
发送消息。侦听verticle启动对后端的非阻塞
调用
,以
从
DB读取所有实体。我的问题是在
调用
DB: ContextNotActiveException时出现异常。@Path("/vertx")public class ApiVertx extends AbstractVerticle {
EventBus
eventBus
) public void getViaSprin
浏览 30
提问于2020-01-27
得票数 0
回答已采纳
1
回答
如何正确地将值
从
RxJava单变量返回到Vertx事件总线使用者
rx-java
、
rx-java2
、
vert.x
<Integer>
consumer
("address", h -> { h.reply} else { } });
从
使用者内部
调用
以下内容如下: vertx.
eventBus
().<Intege
浏览 0
提问于2019-08-01
得票数 1
回答已采纳
1
回答
调用
方法之前的Java泛型表示法是什么?
java
、
generics
我偶然发现了一些带有我不熟悉的泛型符号的示例代码: JsonObject json = message.body();});
浏览 0
提问于2021-05-05
得票数 3
2
回答
正确使用RxJava删除Vert.x回调
rx-java
、
rx-java2
、
vert.x
EventBus
eb = vertx.
eventBus
();MessageConsumer<BusMessage>
consumer
= eb.<BusMessage>
consumer
(address); Observable<Message<BusMessage>> consume
浏览 3
提问于2018-08-15
得票数 1
回答已采纳
0
回答
关于部署verticle的上下文问题的Vertx测试
java
、
vert.x
所以这有点偷偷摸摸的,它不是100%发生的,但情况是这样的: } vertx.deployVerticle(new AbstractVerticle().
consumer
("bla", event -> {}); });
浏览 0
提问于2017-01-09
得票数 1
回答已采纳
1
回答
如何使用vertx.
eventBus
().send()方法将RoutingContext对象
从
routing verticle发送到其他verticle?
vert.x
、
vertx-eventbus
从
我的具有路由URL的路由垂直节点,我想将RoutingContext对象发送到另一个垂直节点。我相信我们只能使用vertx.
eventBus
().send()将消息
从
路由垂直节点发送到其他操作垂直节点。是否可以将RoutingContext对象作为消息发送?在路由器纵向测试中,我正在执行vertx.
eventBus
().<RoutingContext>
consumer
("address").handler(message -> { Routi
浏览 17
提问于2019-08-16
得票数 0
1
回答
Uni等待Vertx
eventBus
消息
quarkus
、
vert.x
、
mutiny
、
vertx-eventbus
waitForEvent() { //wait for event from
eventBus
//
eventBus
.
consumer
("test", msg -> { @Path(&qu
浏览 14
提问于2022-05-08
得票数 0
回答已采纳
1
回答
如何响应来自事件总线使用者的http请求
java
、
vert.x
更改:如何
从
套接字响应http请求。socket.handler(this::onDataReceived);} // get data from the socket send. 2 }
浏览 1
提问于2016-09-19
得票数 1
2
回答
Vertx:如何通过交付方式将消息从一个垂直转发到另一个?
vert.x
我发送一个信息给一个垂直线,这反过来可能需要转发到其他眩晕。我不想编写多余的代码来复制消息头,创建另一个消息对象并传递它。是否有一种方法可以完整地在vert.x中转发消息?
浏览 4
提问于2017-08-24
得票数 0
回答已采纳
1
回答
DeferredResult和反应堆的弹簧异步休息
java
、
spring
、
rest
、
reactor
、
project-reactor
这是我在REST
调用
中为获得与反应堆的异步性所能阐述的最佳方法,以提高可用性:我没有被激活。知道如何做得更好吗?()@RestController public
EventBus
eventBus
DeferredResult<>();
浏览 2
提问于2015-11-22
得票数 0
回答已采纳
1
回答
Reactor
Eventbus
示例,返回响应或错误
java
、
asynchronous
、
project-reactor
在我目前的项目中,我们使用了spring boot和项目反应器,特别是
Eventbus
,来做一些异步处理。我想使用
eventbus
也会让我们的系统更具伸缩性。到目前为止,我们在不返回某些东西的
EventBus
消费者中进行某些处理时,
EventBus
的使用一直相当有限。
eventBus
; private BatchProcessor batchProcessor; public void run(String... arg0BatchProcesspr impl
浏览 0
提问于2016-10-17
得票数 0
1
回答
签名apk中的
Eventbus
错误
java
、
android
、
greenrobot-eventbus-3.0
我就是这样注册和注销的protected void onStart() { mGoogleApiClient.connect();} protected void onStop() {
EventBus
.getDefault
浏览 5
提问于2016-07-25
得票数 2
1
回答
用于非阻塞IO
调用
的aspectj定时器
java
、
aspectj
、
nio
、
vert.x
基本上,我需要获得最初
调用
方法的时间,然后是触发回调的时间(回调总是失败的()或成功的()
调用
,因此我需要将初始的方法
调用
与适当的回调关联起来。我有下面的实现,但是除非
调用
是串行的,否则它不会工作,当然不会这样。
浏览 0
提问于2016-08-10
得票数 1
回答已采纳
3
回答
Spring、Reactor和@
Consumer
spring
、
spring-boot
、
project-reactor
我使用@
Consumer
和@Selector注解来告诉它使用什么类和方法来处理类似这样的事件:public class MyReceiver { }@Autowired ...<e
浏览 1
提问于2016-01-12
得票数 2
1
回答
如何连接JS verticle和Java verticle?
vert.x
、
vertx-verticle
我使用es4x或vertx3-full包在JS(nodeJS)中创建了一个Vertx verticle。我使用npm是因为有一个npm特定的包。现在我有了另一个用Java编写的verticle。我要把这些垂直部分连接起来。该怎么做呢?
浏览 2
提问于2021-10-22
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
熔断、限流的一些理解
企业分布式微服务-Spring Cloud 服务消费Ribbon
深入Kafka系列(二)consumer开发
揭秘 RocketMQ 新特性以及在金融场景下的实践
Kafka是批量发送消息的?
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券