Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
¿Hay algún código de muestra/ayuda para la comunicación entre servicios utilizando grpc en Quarkus? Tenemos 2 servicios y queremos exponer una API de un servicio a otro. He incluido todas las dependencias y he creado el archivo proto. ¿Tengo que mantener el archivo proto en el cliente y en el . . . Read more
Estaba experimentando un poco con los puntos finales REST reactivos de Quarkus en combinación con Reactive mailer para crear una pequeña aplicación que básicamente recibe una imagen y envía esta imagen por correo electrónico. Sin embargo, por alguna razón, si incluyo el archivo adjunto o intento leer desde el flujo . . . Read more
Quiero usar las corrutinas de Kotlin en mis transacciones del cliente SQL reactivo. Para simplificar, iba a usar la función auxiliar proporcionada io.vertx.mutiny.sqlclient.Pool#withTransaction mencionada en la documentación aquí. Dado que la función pasada no es una función de suspensión de corrutina, me está dando un error como Las funciones de . . . Read more
Soy nuevo en el mundo de la programación reactiva. Actualmente estoy trabajando en una aplicación Java reactiva utilizando la biblioteca Mutiny. Necesito desarrollar un bucle que espere a que la iteración anterior finalice para comenzar la próxima. Por ejemplo: List<><t>> uniList = new ArrayList<>(); for (T item : items) { . . . Read more
En el siguiente escenario, si ocurre un error en doSomething, onFailure funciona correctamente: este.restClient.getSomething() .flatMap((algo) -> { return this.restClient.doSomething(); }) .flatMap((res) -> { return Uni.createFrom().item(Response.ok().build()); }).onFailure().transform((e) -> { LOG.error("Error: ", e); throw new InternalServerErrorException("Error!"); }); El problema es que si el error ocurre en getSomething, onFailure no se llama y . . . Read more