Questions tagged [smallrye-reactive-messaging]
107 questions
6
votes
1 answer
How to handle error - SRMSG00034: Insufficient downstream requests to emit item
I am load testing a simple application developed in Quarkus. The application proxies http request to another http service.
The application uses org.eclipse.microprofile.reactive.messaging.Emitter and…
anaray
- 309
- 1
- 8
5
votes
1 answer
Uni how to get failure or success response at REST call
I'm trying to setup a simple success / failure response after a email was sent by the server.
However, even after hours of trying many variants, I still doesn't get the correct response.
The example code that just gives a response accepted is…
Hans Bondoka
- 437
- 1
- 4
- 14
4
votes
1 answer
Quarkus - Responding with status based on kafka write ack and nack
I have an endpoint which pushes data to kafka. Now, I want to respond to the call with the appropiriate status code 2xx or 5xx in case of kafka write success or failure respectively. The code snippet is
@Path("/prices")
public class PriceResource…
rightjoin
- 77
- 8
4
votes
1 answer
Quarkus + Kafka + Smallrye exception handling
How can i handle exception on streaming processing with quarkus + kafka + smallrye?
My code is very similar to the imperative producer example on quarkus guide (https://quarkus.io/guides/kafka#imperative-usage)
import…
tcsdev
- 191
- 1
- 2
- 7
4
votes
0 answers
AMQP consumer stops receiving on 127th message
PROBLEM: The publisher app continuously publishes AMQP messages to Artemis broker - but, the consumer app stops receiving messages after the 127th.
Fwiw - Coincidentally, noticed an excerpt from a Smallrye web page cites:
"the default buffer size…
sairn
- 461
- 3
- 24
- 58
3
votes
1 answer
How do I properly publish tombstone messages to compacted kafka topic from within a quarkus application?
From within a Quarkus application I need to publish tombstone messages to a compacted Apache Kafka topic. As my use-case is imperative I use an Emitter for sending messages to the topic (as suggested in the quarkus blog). The code for non-tombstone…
m o
- 1,807
- 2
- 11
- 12
3
votes
1 answer
Dynamic Topic Name / Quarkus SmallRye Reactive Messaging Kafka
I want to use this extension: [Quarkus Smallrye Reactive Messaging Kafka]
But in my application the name of the topics is not known in advance, it is specified according to the message received from the user at runtime. How can I specify the topic…
EbiPenMan
- 49
- 5
3
votes
1 answer
Publish / Subscribe MQTT using SmallRye reactive messaging dynamically
We try to publish and subscribe to MQTT protocol using smallrye reactive messaging. We managed to actually publish a message into a specific topic/channel through the following simple code
import io.smallrye.mutiny.Multi;
import…
Panagiss
- 3,154
- 2
- 20
- 34
3
votes
1 answer
Restart Reactive Messaging, e.g. after reconfigure
How can I restart or stop/resume the reactive messaging, e.g. after changing the interval time?
This example is from the Quarkus guide: https://quarkus.io/guides/kafka-streams
@Outgoing("temperature-values")
public…
Kevin
- 1,232
- 10
- 28
3
votes
1 answer
Using io.smallrye.mutiny.Uni to create a response object
I am trying to learn using ReactiveMongoClient on a Quarkus framework.
I am partly successful with sending a response as Uni>
@GET
@Path("/unpaginated")
public Uni> unpaginatedStaffList() {
return…
Mustaq
- 35
- 1
- 5
3
votes
1 answer
Send amqp message with headers in quarkus
I want to send a Java (well Kotlin) POJO as JSON in an AMQP message to RabbitMQ using Quarkus.
@Path("/amqp")
class TestSource {
@Inject
@Channel("amqpwrite")
lateinit var emitter: Emitter
@POST
…
yogiginger
- 1,075
- 4
- 13
- 25
2
votes
0 answers
Quarkus Hibernate Reactive Panache, No current Vertx context found on some database wrights
Using Quarkus hibernate Reactive Panache and the quarkiverse.reactivemessaging.http dependency trying to wright some data from a websocket connection into the database.
Works as expected but getting the following error on sum attempts.
Failed to…
alick
- 21
- 3
2
votes
1 answer
Quarkus - SmallRye Reactive Messaging - RabbitMQ: Send message to default exchange
Using the remote procedure call pattern, I need to send an answer to a reply-queue, i.e. I need to send the message to the default exchange with the name of the queue as the routing key.
I am using the SmallRye Reactive Messing RabbitMQ plugin on…
ReactiveMessenger
- 21
- 2
2
votes
0 answers
Maintaining the original traceId while passing messages through Kafka with quarkus and opentracing
I'm trying to create the most basic working example with two Quarkus (2.4.1.Final) microservices (a producer and a consumer) that communicate through Kafka and are traced with opentracing.
I have followed the kafka and the opentracing tutorial, ran…
Mihai P.
- 291
- 3
- 11
2
votes
2 answers
How to unit test a method returning Uni/Multi of Smallrye mutiny reactive library?
I am using Smallrye Mutiniy reactive library in my Quarks application as it is supported natively in Quarks applications.
I'am trying to write unit tests for a service class. I am not sure how to write unit tests for a method that returns…
Player_Neo
- 1,413
- 2
- 19
- 28