有人知道在Quarkus测试中监视Vert.x事件总线的方法吗?理想情况下,我希望断言,在服务层的方法期间,我们将事件发送到正确的地址,但有人知道这是否可能吗?
如果我只是尝试使用@injectmock
,我会得到以下错误
io.vertx.core.eventbus.impl.EventBusImpl@5769679b is not a normal scoped CDI bean, make sure the bean is a normal scope like @ApplicationScoped or @RequestScoped
通过在EventBus周围创建一个ApplicationScoped委托,我解决了这个问题。这个委托可以在Quarkus中作为正常bean进行模拟和检查。所有直接使用EventBus的bean都需要使用EventBusDelegate。在测试中,可以使用@injectmock注释注入mocked的EventBusDelegate。
我是Vert.x.中活动巴士的新手https://vertx.io/docs/vertx-core/java/,描述如下: 尽最大努力交付 Vert.x尽最大努力传递消息,并且不会有意识地丢弃它们。这称为尽力而为的交付。 如果您的应用程序关心丢失的消息,您应该将您的处理程序编码为等幂,并将您的发送程序编码为在恢复后重试。 我的系统不希望丢失任何消息,所以我必须了解事件总线并决定是否使用Vert.
我正在使用vert。x 2.1.5版本。我试图在我的项目中使用事件循环。下面给出了示例代码 在此代码中,我的事件总线在执行事件循环之前返回值。我需要根据事件循环输出填充我的输出 如何实现
让我们跳进 API 获取事件总线 你获取到事件总线的引用,如下所示: EventBus eb = vertx.eventBus(); 还有每个 Vert.x 实例事件总线的单个实例。 注册处理程序 这个最简单的方法来注册一个处理程序用consumer。下面是一个示例: EventBus eb = vertx.eventBus(); eb.consumer("news.uk.sport", mess
注:本节未经校验,如有问题欢迎提issue 最初设想是为了提供一种向多个actor群发消息的方法,之后EventBus被一般化为一组实现一个简单接口的可组合的特质: /** * Attempts to register the subscriber to the specified Classifier * @return true if successful and false if not
本文向大家介绍你有用过事件总线(EventBus)吗?说说你的理解相关面试题,主要包含被问及你有用过事件总线(EventBus)吗?说说你的理解时的应答技巧和注意事项,需要的朋友参考一下 https://blog.csdn.net/xr510002594/article/details/96431090
背景 JDK中通过Observer接口和Observable类实现观察者模式, Observer对象是观察者,Observable对象是被观察者. 实现一个简单的观察者模式有以下几步: 创建被观察者, 继承自java.util.Observable类 创建观察者, 实现java.util.Observer接口 在观察者中实现void update(java.util.Observable obse