Описание тега mutiny
Mutiny - это библиотека реактивного программирования, управляемая событиями, для Java 8+.
1
ответ
Нет отката с кваркусом, бунтом и реактивным postgresql
Я пытаюсь выполнить 3 вставки в рамках одной транзакции, но не могу выполнить откат транзакции, если одна из вставок завершилась неудачно. Я новичок в реактивном мире, и это мое самое первое реактивное приложение. Вот упрощение модели базы данных: E…
07 июн '20 в 19:47
1
ответ
Uni <Void> как получить ответ об ошибке или успехе при вызове REST
Я пытаюсь настроить простой ответ об успехе / неудаче после того, как сервер отправил электронное письмо. Однако даже после нескольких часов перебора множества вариантов я все еще не получаю правильного ответа. Пример кода, который просто дает ответ…
13 июн '20 в 19:38
0
ответов
Соединение закрыто, пока идет рукопожатие с веб-сокетами
У меня проблема при отправке сообщения на сервер websocket. 2020-06-15 17:06:51,830 INFO [snc.mob.gro.myt.con.ws.MutinyWebsocket] (vert.x-eventloop-thread-6) erreur {}: io.netty.handler.codec.http.websocketx.WebSocketHandshakeException: Connection c…
15 июн '20 в 18:21
1
ответ
Как я могу вставить и получить последний вставленный идентификатор в mysql с транзакциями, используя реактивный клиент mysql quarkus с api mutiny
Как мне создать транзакцию, вставить строку, зафиксировать транзакцию и получить последний вставленный идентификатор. Таким образом, метод должен вернутьUni<Integer>. Я новичок в api мятежа, раньше я использовалvertx.ioцепочка будущих обработч…
16 июн '20 в 13:07
1
ответ
Управление подтверждением с помощью Mutiny при преобразовании сообщения в Multi <Message>
Я пытаюсь преобразовать одно входное сообщение в несколько сообщений. У меня есть метод со следующей подписью: @Incoming("CH_IN") @Outgoing("CH_OUT") Multi<Message<B>> process(Message<A> in) { } Класс A как: class A { private List&…
20 июн '20 в 10:52
1
ответ
Что такое http-коды при возврате возможно нулевого Uni или пустого Multi в reasteasy?
Где я могу найти документы для http-кодов при возврате возможно нулевого или пустого Uni/Multi? Я обнаружил, что возвращение возможно нулевого значения Uni возвращает http-статус 204 (без содержимого) при использовании запроса на получение, такого к…
27 июн '20 в 21:28
0
ответов
Quarkus mutiny - отсутствует поддержка OAuth2 для веб-клиента
У меня есть базовая реализация в Quarkus/mutiny (реактивная), и я могу использовать REST API, используя артефакт smallrye-mutiny-vertx-web-client. Поскольку я использую mutiny, Vertx импортируется из io.vertx.mutiny.core.Vertx. Я не нашел совместимо…
18 авг '20 в 18:32
2
ответа
quarkus: IllegalStateException: вы попытались выполнить операцию блокировки в потоке ввода-вывода. Это недопустимо, так как блокирование потока ввода-вывода
Есть одна вещь, которую я не могу понять с кваркусом. Я использую JPA с Oracle. Итак, у меня ошибка IllegalStateException: вы попытались выполнить операцию блокировки в потоке ввода-вывода. Это недопустимо, так как блокирование потока ввода-вывода я…
21 май '20 в 15:13
0
ответов
SmallRye Mutiny и распространение контекста
Новый (в некоторой степени) реактивный API для Quarkus великолепен, но он вносит некоторую сложность при написании кода (во многом как в асинхронном коде в JavaScript, на мой взгляд). Как он интегрируется с API метрик / трассировки /jwt? или что-ниб…
06 авг '20 в 11:04
1
ответ
Quarkus: v.1.5.1 PgPool подготовил запрос с параметрами?
Как правильно выполнить подготовленный оператор с параметрами в версии Quarkus 1.5.1? Как я вижуpreparedQuery() метод PgPool class нет второй Tuple аргумент как в версии 1.4.2. Определение в smallpye-mutiny-vertx-sql-client-0.0.15.jar класса Pool: p…
15 июн '20 в 11:30
1
ответ
Неблокирующая потоковая передача данных между двумя сервисами Quarkus (Vert.x с Mutiny в Java)
Обновить! Я исправил мелкие ошибки в примере кода после решения некоторых проблем, которые не имели отношения к основному вопросу, который все еще касается неблокирующей потоковой передачи между сервисами. Справочная информация: Я портирую службу Sp…
29 авг '20 в 19:20
1
ответ
Quarkus: выполнить параллельный unis
В приложении quarkus / kotlin я хочу запускать несколько запросов к базе данных одновременно. Я новичок в quarkys и не уверен, что все делаю правильно: val uni1 = Uni.createFrom().item(repo1).onItem().apply { it.request() } val uni2 = Uni.createFrom…
11 сен '20 в 11:40
1
ответ
Мятеж: восстановление после единственного тайм-аута
Из приложения quarkus (kotlin) я запрашиваю несколько конечных точек (одна и та же конечная точка, но с другим базовым URL) параллельно, а затем комбинирую uni, чтобы не ждать последовательно каждого ответа. Вот пример: val unis = repository.findUni…
08 окт '20 в 15:16
1
ответ
Как справиться с полной компенсацией с помощью Mutiny?
Работая над Quarkus и SmallRye Mutiny, я не знаю, как поступать с компенсациями. У меня есть список сотрудников, и я должен обновить их всех в базе данных. Объект доступа к данным (EmployeeDao) имеет следующий метод: public Uni<Boolean> update…
12 ноя '20 в 14:26
1
ответ
Quarkus: блокировка метода службы grpc, работающего в цикле событий
Я реализую сервер gprc в quarkus (1.8.3.Final). Мой сервис написан в реактивном стиле (smallrye mutiny) Это мой класс обслуживания @Singleton @Blocking @Slf4j public class GrpcService extends MutinyGrpcServicesGrpc.GrpcServicesImplBase{ @Blocking pu…
05 дек '20 в 19:36
3
ответа
Как отсортировать мульти в smallrye mutiny
Другие реактивные библиотеки, такие как projectactor, предлагают методы сортировки для издателей, но в бунте такого метода нет. В их документации об этом даже не говорится. https://smallrye.io/smallrye-mutiny Прямо сейчас я достигаю указанной функци…
15 окт '20 в 21:34
0
ответов
Как повторно вызвать исключение в шине событий vert.x с помощью Smallrye Mutiny
Я пытаюсь использовать шину событий quarkus в качестве шины сообщений для реализации простой реализации шаблона команд. Я использую механизм запроса / ответа. Я отправляю сообщение из ресурса обработчику команд, прослушивающему тот же канал. Я пытаю…
08 окт '20 в 04:53
0
ответов
Как вставить запись с мятежом и mysql?
При попытке вставить записи в базу данных MySQL ничего не вставляется. Вот использованный исходный код: public Uni<Tenant> persist(Tenant tenant) { return client.preparedQuery("INSERT INTO TENANT (ID, NAME, ACTIVE, CREATED_DATE, UPDATED_D…
29 ноя '20 в 14:37
1
ответ
Каковы преимущества / недостатки javax.enterprise.event по сравнению с org.eclipse.microprofile.reactive.messaging?
Я пытаюсь изучить реактивное программирование / обмен сообщениями с помощью QUARKUS и SmallRye. Но мне все еще трудно понять преимущества org.eclipse.microprofile.reactive.messaging перед javax.enterprise.event, если есть? С одной стороны: @Inject M…
26 ноя '20 в 18:52
1
ответ
Веб-клиент Quarkus Mutiny безопасно декодирует JSON
Я начал работать с Quarkus и пытался использовать Mutiny Vertx WebClient. Мой код работает, но я предпочитаю не полагаться на небезопасные / непроверенные назначения, как я сейчас написал код с помощью метода bodyAsJson в HttpResponse. Есть ли лучши…
28 ноя '20 в 08:25