smallrye-reactive-messaging
smallrye-reactive-messaging copied to clipboard
SmallRye Reactive Messaging
As discussed in #2115, this introduces some CDI extensions to act as a bridge for environments where auto bean discovery is not utilized. A consumer can chose to explicitly add...
This issue was discovered while using the smallrye-reactive-messaging-kafka Quarkus extension with their QuarkusIntegrationTest annotation test with some configuration overrides. But it besically boils down to an issue of smallrye-reactive-messaging-provider to...
Hi, I went through the documentation but I cannot find anything related to the JTA. I would like to know if is it possible to create transaction towards RabbitMQ in...
I would like to configure a decorator per connector. When `isConnector` is `true`, would it be possible to pass a `ConnectorConfig` instance of the given connector to the decorate method...
Bumps [io.sundr:sundr-maven-plugin](https://github.com/sundrio/sundrio) from 0.103.1 to 0.200.0. Commits See full diff in compare view [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter...
WIP: Initial commit with 2 simple fault strategies for jms. I need a little help, creating tests for these. I looked into how it is done for kafka, but it...
Bumps [io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha](https://github.com/open-telemetry/opentelemetry-java-instrumentation) from 1.31.0-alpha to 2.3.0-alpha. Release notes Sourced from io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha's releases. Version 2.2.0 This release targets the OpenTelemetry SDK 1.36.0. Note that many artifacts have the -alpha suffix attached...
We have discussed a bit about acknowledgement, when using CLIENT_ACKNOWLEDGE during the jms connector. When i try this and my Inbound annotated method throws an Exception, this results in the...
In reference to the discussion from this issue [https://github.com/smallrye/smallrye-reactive-messaging/issues/2548#issuecomment-2037205262](https://github.com/smallrye/smallrye-reactive-messaging/issues/2548#issuecomment-2037205262) The backpressure mechanism in the SmallRye Pulsar connector does not consider memory limit settings. While Pulsar clients can be configured with...
Bumps [io.opentelemetry.semconv:opentelemetry-semconv](https://github.com/open-telemetry/semantic-conventions-java) from 1.21.0-alpha to 1.25.0-alpha. Release notes Sourced from io.opentelemetry.semconv:opentelemetry-semconv's releases. Version 1.24.0 NOTICE: This release contains a significant restructuring of this repository and the generated classes as we...