问题标签 [smallrye]

我有以下方法：

这将返回一个 Uni，该值需要在此方法创建的 OutcodeStats 对象中设置：

不幸的是，我不知道如何将两者结合起来以设置hmoStatsOutcodeStats 对象的属性。

一种解决方案可能是getHMOStats不返回 Uni，但我不认为这是要走的路。

感谢您的关注。

首先，我假设Bulkhead 模式不适用于基于 Vertx/Quarkus/等的事件循环应用程序。我的具体用途是公开一个 REST API，然后调用另一个 REST API。我知道我需要断路器模式，但我看不到 Bulkhead 的用途，因为根据定义，如果所有传入请求都是异步非阻塞的，那么它们不应该相互影响。

其次，我有需要在工作人员内部运行的阻塞代码。我假设如果我创建一个垂直工作流并扩大到说 3 个实例，而不是如果每个工作人员都在单独的线程上运行，我有效地创建了一个 Bulkhead？我了解单个线程上的 3 个工作人员不是 Bulkhead 模式。

我有两个可用的 gRPC 端点和一个 ServerInterceptor，它应该在抛出异常时拦截异常。

gRPC 服务定义如下：

gRPC 服务使用 SmallRye Mutiny Reactive 来处理请求。

其他帖子解释说，onHalfClose应该重写该方法并插入一个 try/catch 块以捕获自定义异常，然后将其映射到可以使用的 StatusRuntimeException gRPC。我尝试了以下方法：

该handleException方法将 Throwable 映射到 StatusRuntimeException 并抛出 StatusRuntimeException。

到目前为止一切顺利，当运行应用程序并模拟自定义异常时，ExceptionInterceptor 确实进入了该onHalfClose方法。但是，即使抛出了异常，它也不会进入 catch 块。而是将此错误消息记录到控制台：

2022-01-24 12:07:36,232 WARN [io.qua.grp.run.ServerCalls] (executor-thread-0) gRPC service threw an exception other than StatusRuntimeException

如何解决这个问题？

只是让我了解 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

我有一个使用 Quarkus Hibernate ORM 的 Quarkus 微服务，并且想要创建一个从数据库中读取值的指标仪表。不幸的是，每当我尝试读取该值时，Hibernate 事务处理程序都会抛出一个javax.enterprise.context.ContextNotActiveException.

这是我使用 Smallrye 指标的代码：

这是我尝试使用 Quarkus Micrometer 注册表：

两种方法都不起作用，因为两者都ContextNotActiveException被抛出。似乎请求上下文没有传播（显然没有），没有它实体管理器就无法工作。

那么从数据库中读取仪表的正确方法是什么？

更新：

@Transactional通过将注释添加到仪表方法，我可以使用 Smallrye 指标。

问题

更改为 后quarkus.package.type，fast-jar我们 Kubernetes 集群上的应用程序实例无法再读取已挂载的 ConfigMap。

本地配置没有问题，但我们也没有挂载它 - 只是有一个 static application.yml。在此更改之前一切正常，我们可以直接将其跟踪到quarkus.package.type.

我们的设置

首先也是最重要的：我们不使用 a application.properties，而是使用 a application.yml（利用quarkus-config-yaml）。

我们正在使用 Quarkus 2.7.1.Final。

Java 代码

部署

我们的 application-config.yaml (ConfigMap)：

我们的 deployment.yaml（部署）：

杂项

1. 我找不到任何好的信息，在读取配置之间可能发生了什么legacy-jar变化fast-jar。也许它与不同的结构有关（如此处所示）。对我来说，这可能是最可能的错误来源。

   1.1。我尝试将挂载路径从更改/config为/usr/local/apps/config（遵循此SmallRye ConfigMap 示例），但无济于事。

   1.2. 我也尝试将挂载的文件从 to 重命名application.yml，application.yaml但结果相同。

我在单元测试中尝试模拟 smallrye-graphql-client 时遇到了一些问题。我认为这将是一个类似于模拟 RestClient https://github.com/quarkusio/quarkus/issues/9630的过程， 但它不是那样工作的。

GraphQL 客户端：

测试：

应用程序.yaml

错误信息：

如何在 Quarkus 中模拟 smallrye-graphql-client？

预先感谢您的帮助