问题标签 [micronaut-rest]

我正在尝试从 Micronaut kafka 实现中获取非阻塞响应，但是返回值不起作用。

subscribe 方法不起作用，调试器永远不会到达这一点。我想从kafka监听器那里取回价值

卡夫卡制作人

卡夫卡监听器

非阻塞方法的 Micronaut 文档

https://docs.micronaut.io/1.0.0.M3/guide/index.html#_reactive_and_non_blocking_method_definitions

试图在 Micronaut 应用程序中获取 POJO 属性名称。我有以下 POJO 类

我知道我们可以使用Introspected

下面的代码以数组形式为我提供了所有属性。

现在产品包含属性名称字符串，

我需要获取如下的单个属性而不是 foreachproduct

除了通过数组，有没有什么方法可以直接访问它，类似于 Lombok，如下所示

有什么办法可以做到这一点？

上下文：我将 Kotlin 与 Micronaut 一起使用，对于这个项目，我不会添加 Spring 依赖项。

我成功创建了一个 Hello Word 端点，我可以从 Postman 向它发帖。当我将数据演变为生日（java.time.LocalDate）时，问题就开始了。

复制自邮递员

导致

实体

控制器

gradle.properties 依赖项

gradle.properties

整个项目git hub（分支date_issue中的错误，不在master中）

我正在尝试使用 Micronaut AMQP 执行请求/响应模式，如下图

制片人

听众

对于它正在工作的请求，了解如何执行返回给控制器的响应以及如何使用 AMQP 协议和 micronaut 与消息代理异步实现此模式。

使用具有直接消息交换机制的 Micronaut RabbitMQ，在将值从侦听器返回给生产者时，出现如下所述的 JSON 解析器错误

听众

制片人

控制器

对于单个项目列表，不会出现异常，但是，对于超过 1 个值，会出现异常。由于我使用的是Flowable它应该像一个LIST

我正在尝试在 Micronaut 中使用 RabbitMQ 获得代理确认。

听众

控制器

制片人

更新 - #1

根据文档

客户端方法支持两种返回类型，void 和反应类型。如果该方法返回 void，则消息将被发布并且该方法将在没有确认的情况下返回。如果响应类型是返回类型，则将返回一个可以订阅的“冷”发布者。

但是在控制器System.out.println(item);中，确认永远不会得到。

尝试在 Micronaut 2.2.1 中实现处理消费者异常https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#consumerExceptions

根据文档

如果消费者 bean 实现了 RabbitListenerExceptionHandler，那么异常将被发送到方法实现。

如果消费者 bean 没有实现 RabbitListenerExceptionHandler，那么异常将被路由到主异常处理程序 bean。要覆盖默认异常处理程序，请将 DefaultRabbitListenerExceptionHandler 替换为您自己的指定为 @Primary 的实现。

运行时异常

如何覆盖 RabbitListenerExceptionHandler ？

我在 Micronaut 2.2.1 中使用 Java 15 记录功能，序列化不起作用

产品视图模型记录

控制器

我正在尝试处理从 Rabbit Listener 引发的异常并将错误暴露给 Rest 端点。

兔子听众

从侦听器中我抛出了一个异常，它的处理RabbitListenerExceptionHandler如下所示

现在我有一个全局异常处理程序，它处理 HTTP 请求和响应。

当我throw new GlobalException();从RabbitListenerExceptionHandler异常中没有被观看时GlobalExceptionHandler

我得到一个例外

对记录类使用 Micronaut bean 验证不起作用

记录类

卷曲

控制器方法

错误为

注释过程已启用。

构建.Gradle