smallrye-reactive-messaging
smallrye-reactive-messaging copied to clipboard
smallrye
SmallRye Reactive Messaging
Hello I could not get the InMemmoryConnector Example from the documentation https://smallrye.io/smallrye-reactive-messaging/smallrye-reactive-messaging/3.3/testing/testing.html running. Did I do something wrong or is the documentation not complete? Steps to reprodice: 1. Got a...
It would be useful to have a notion of "message interceptors" for cases when you want to apply some cross-cuting logic to all messages on a number of channels (one,...
When using failure strategy "dead-letter-queue", nacked messages are copied into the dead letter topic, with new headers: dead-letter-reason, dead-letter-offset, dead-letter-partition, dead-letter-topic, dead-letter-cause. Right now those headers are hard coded into...
I´m migrating a spring app to quarkus and one of my feature is create an object using RPC with rabbitmq queue. In spring there is one way to do that,...
i want to use request reply mode (send to queue after that, send another random queue) [( https://www.rabbitmq.com/direct-reply-to.html)] i using camel oke, but this lib, i dont know implement that....
In my current Quarkus project i'm using `Emitter` together with `smallrye-reactive-messaging-jms` to send messages to a JMS queue. It works fine, until the first connectivity issue with the message server...
## Reactive messaging should work with Producer methods Today the ReactiveMessagingExtension only considers Fields as CDI InjectionPoints for Emitters and Consumer methods annotated with @Channel. This requires us to create...
When using an `@Incoming` method annotated with `@Blocking` and `@WithSpan`, the `Span.current()` is the `Span.getInvalid()` inside the method body, at least when the test message is sent by means of...
Fixes #1769 ### `IncomingMessageConverter` / `MessageConverter` ## Deprecate `MesasgeConverter` `MessageConverter`'s interface is synchronous which does not allow it to handle failures in any meaningful way. First, if message conversion fails...
