smallrye-reactive-messaging

smallrye-reactive-messaging copied to clipboard

Messages sent to the DLQ topic are not counted in micrometer metrics.

2

In case of the failure-strategy set to dead-letter-queue, if there is an exception while processing the message, the message can be consumed from the dead-letter queue topic, as described in...

Annlazar

[Kafka Test Companion] Inconsistent handling of properties

1

### The problem In Kafka Test Companion's `ProducerBuilder` and `ConsumerBuilder`, the properties seem to be treated inconsistently: - The constructors of both `ProducerBuilder` and `ConsumerBuilder` use the signature `Map` -...

Abaudat

The `emitter.hasRequests` method does not take into account the buffer size

10

We need to send a large number of events at the same time to a Kafka topic through an emitter: ```java public class EmitterService { private final Emitter emitter; public...

Sgitario

Usage without Quarkus or auto bean discovery

13

I'm hoping to use this implementation of MP Reactive Messaging outside of Quarkus. I'm primarily trying to spin up some Kafka consumers in a Vert.x app. Initially it seemed straightforward...

craig-day

AMQP - client reconnect-interval configuration property docs misleading

2

Documentation `reconnect-interval` configuration property of AMQP client is misleading. [Please see here](https://smallrye.io/smallrye-reactive-messaging/3.22.0/amqp/receiving-amqp-messages/#configuration-reference) Below is mentioned in the docs :  But this is not the correct behavior of client [see...

stackoverflow2

JMS specifications has a couple of constraints/limitations: 1) message acknowledgment is disallowed from a thread other than the message delivery thread of the Session that runs the MessageListeners. Jackarta group...

fsantagostinobietti

Bumps [io.opentelemetry.semconv:opentelemetry-semconv](https://github.com/open-telemetry/semantic-conventions-java) from 1.21.0-alpha to 1.23.1-alpha. Release notes Sourced from io.opentelemetry.semconv:opentelemetry-semconv's releases. Version 1.22.0 Update to semconv 1.22 (#29) Compile only opentelemetry-api dependency (#30) 🙇 Thank you This release was...

dependabot[bot]

RabbitMQ - print "SRMSG17038: No valid content_type set" when content encode set

6

I use quarkus-smallrye-reactive-messaging-rabbitmq in my quarkus project provide: ```java @Incoming("test-a") @Outgoing("test-b") public Message provide(Message message) { final OutgoingRabbitMQMetadata metadata = new OutgoingRabbitMQMetadata.Builder() .withContentEncoding(StandardCharsets.UTF_8.name()) .withContentType("application/json") .build(); System.out.printf(new String(message.getPayload())); message.ack(); return Message.of(new...

xiyuanpingtadi

RabbitMQ - Possibility to bind different exchanges to queue .

1

Would be nice to have possibility to setup binding to queue different exchanges with routing key .

MaysonD

At the moment, we cannot handle the demand correctly after a reconnection. The underlying RabbitMQ client (from Vert.x) requests Long.MAX_VALUE item, in this case, ignores the application demands. As a...

cescoffier