问题标签 [mutiny]

给定 Quarkus 应用程序中的订阅：

如果我理解正确，processA将在调用者线程上执行（所以如果它在 Verticle 中，它应该在 IO 线程上），processB并将processC在工作线程上执行，processD将再次在调用者/IO 线程上。

我怎样才能processC在 IO 线程上被调用，同时processB仍在工作线程上？有没有一种简单的方法可以将事件带回调用者线程？

编辑：现在我正在使用以下解决方法：

我想做一个类别树，这里是类别结构

开头的children是空的，如果null是parent，则parentId是parent，否则是children。我想返回这个结果：

我用经典编程做了我想用兵变 smallrye 迁移到反应式编程这是我的代码：

我只是在学习 Mutiny，我需要实现重试逻辑。

我有这个代码：

因此，这getResult()是一个可能行为不端的函数，需要在失败时多次调用。

当我运行这个程序时，这就是发生的事情：

显然，该getResult()函数只调用了一次，而各个onFailure()阶段实际上执行了 3 次。

Mutiny 有什么可以帮助我getResult()在每次失败时执行功能的吗？我当然可以用一个简单的循环来实现它，但我觉得 Mutiny 应该已经有了这样的东西。

不幸的是，我在文档中没有找到任何合适的东西。

我想就如何正确实施这一点以及这是否是正确的方法获得意见。因此，我使用反应式消息创建了一个完全反应式的应用程序，但我知道我有一个总体约束——那个约束是 Oracle。如您所知，JDBC 本质上是阻塞的，不能真正异步执行。我试图找出一种方法来实现这一点，这样事件循环线程就不会被阻塞，到目前为止，唯一可行的事情是这样的：

我已经设法让它按原样工作，但我不确定这是否是正确/有效的方式。有没有人对如何完成这样的任务有任何建议？任何建议都非常感谢和考虑，谢谢！

我正在努力实现 gRPC 通信。有一个 maven 项目有两个模块，它们应该使用 gRPC 进行通信。

从 *.proto-files 生成的类包含SessionServiceInterface，它实际上是一个 MutinyService 接口。（以下部分实现）

运行这两个项目会导致以下错误：

错误本身说“只有 Mutiny 服务接口 [...] 可以通过 @GrpcClient 注入”

现在我很困惑。我在这里做错了什么还是这是一种奇怪的行为？希望你有一些想法；）

接口 session.proto：

会话服务.java：

服务器-'application.properties'：

会话客户端.java：

客户端-'application.properties'：

和 pom.xml 的：

项目：

客户端模块：

服务器项目：

运行此方法时会引发ClassCastException：

consume has thrown an exception: java.lang.ClassCastException: class java.lang.String cannot be cast to class io.smallrye.mutiny.Multi

我可以消费Multi<String>吗？

查看SmallRye Reactive Messaging > Development Model > Consuming Payloads似乎我一次只能使用一条消息。

I'm running Quarkus 2.7.0.CR1 with this code:

onFailure() triggers if port in URL is not responding at all. But when returning HTTP 500 from WireMock this code just throws WebApplicationException with status 500 without triggering onFailure(). This is the exception that triggers onFailure():

AnnotatedConnectException seems to be checked exception but in this example IllegalArgumentException is used which is RuntimeException like WebApplicationException.

I thought onFailure() should trigger on any exception. Any ideas what is going on? I have tested with @QuarkusTest and also by running Quarkus locally with mvn compile quarkus:dev.

只是让我了解 Mutiny API（和 java 流 api）......

我有以下代码从 AWS SQS 队列中读取消息，参考：quarkus sqs guide

接下来我想将列表中的每个元素发送到一个方法handleMessage(Quark quark)。我该如何以“叛变的方式！”做到这一点。我需要再次转换还是不应该收集..或者？

我们正在使用 quarkus 来处理在常规函数上运行的消息，因为我们suspend基本上必须调用一个函数

我们希望将数据作为Uni（https://smallrye.io/smallrye-mutiny/getting-started/creating-unis）所以基本上我们想回来

我们需要进一步下游的 uni 来处理一些数据，但我们想Uni从方法中返回 a

我是反应式编程的新手。请协助在 Mutiny 中实现以下目标。

我有一个 DTO 课程

3种服务方式，一种退货Uni，另一种退货Multi。

我需要编写一个调用上述 3 个方法的服务方法，应用一些业务验证，将返回值设置为一个实例UserAppSessionDto并返回一个Uni<UserAppSessionDto>. 我已经提到了下面要应用的基本业务逻辑（空检查）。