Switch to Vert.x 5 and New RabbitMQ connector

.github/workflows/build-main-branches.yml

@@ -114,10 +114,10 @@ jobs:
                 connector:
                     -   name: AMQP
                         artifact: smallrye-reactive-messaging-amqp
-                    -   name: MQTT
-                        artifact: smallrye-reactive-messaging-mqtt
+#                    -   name: MQTT
+#                        artifact: smallrye-reactive-messaging-mqtt
                     -   name: RabbitMQ
-                        artifact: smallrye-reactive-messaging-rabbitmq
+                        artifact: smallrye-reactive-messaging-rabbitmq-og
                     -   name: Pulsar
                         artifact: smallrye-reactive-messaging-pulsar
                     -   name: GCP Pub/Sub

.github/workflows/build-pull.yml

@@ -113,10 +113,10 @@ jobs:
                 connector:
                     -   name: AMQP
                         artifact: smallrye-reactive-messaging-amqp
-                    -   name: MQTT
-                        artifact: smallrye-reactive-messaging-mqtt
+#                    -   name: MQTT
+#                        artifact: smallrye-reactive-messaging-mqtt
                     -   name: RabbitMQ
-                        artifact: smallrye-reactive-messaging-rabbitmq
+                        artifact: smallrye-reactive-messaging-rabbitmq-og
                     -   name: Pulsar
                         artifact: smallrye-reactive-messaging-pulsar
                     -   name: GCP Pub/Sub

documentation/mkdocs.yml

@@ -70,6 +70,15 @@ nav:
         - 'Connecting to managed instances' : rabbitmq/rabbitmq-cloud.md
         - 'RabbitMQ Request/Reply': rabbitmq/request-reply.md
 
+  - RabbitMQ OG:
+        - rabbitmq-og/rabbitmq-og.md
+        - 'Receiving messages' : rabbitmq-og/receiving-messages-from-rabbitmq.md
+        - 'Sending messages' : rabbitmq-og/sending-messages-to-rabbitmq.md
+        - 'Health Checks' : rabbitmq-og/rabbitmq-og-health.md
+        - 'Client Customization' : rabbitmq-og/rabbitmq-og-client-customization.md
+        - 'OpenTelemetry Tracing' : rabbitmq-og/rabbitmq-og-tracing.md
+        - 'Connecting to managed instances' : rabbitmq-og/rabbitmq-og-cloud.md
+
   - Pulsar:
         - pulsar/pulsar.md
         - 'Receiving messages': pulsar/receiving-pulsar-messages.md
@@ -93,12 +102,6 @@ nav:
         - 'Sending JMS messages' : jms/sending-jms-messages.md
         - 'Advanced configuration' : jms/advanced-jms.md
 
-  - MQTT:
-        - mqtt/mqtt.md
-        - 'Receiving MQTT messages': mqtt/receiving-mqtt-messages.md
-        - 'Sending MQTT messages': mqtt/sending-messages-to-mqtt.md
-        - 'Customizing the MQTT client': mqtt/client-customization.md
-
   - AWS SQS:
         - sqs/sqs.md
         - 'Receiving AWS SQS messages': sqs/receiving-aws-sqs-messages.md

documentation/pom.xml

@@ -65,12 +65,12 @@
     </dependency>
     <dependency>
       <groupId>io.smallrye.reactive</groupId>
-      <artifactId>smallrye-reactive-messaging-mqtt</artifactId>
+      <artifactId>smallrye-reactive-messaging-rabbitmq</artifactId>
       <version>${project.version}</version>
     </dependency>
     <dependency>
       <groupId>io.smallrye.reactive</groupId>
-      <artifactId>smallrye-reactive-messaging-rabbitmq</artifactId>
+      <artifactId>smallrye-reactive-messaging-rabbitmq-og</artifactId>
       <version>${project.version}</version>
     </dependency>
     <dependency>

documentation/src/main/docs/rabbitmq-og/rabbitmq-og-client-customization.md

@@ -0,0 +1,49 @@
+# Customizing the underlying RabbitMQ client
+
+You can customize the underlying RabbitMQ Client configuration by
+*producing* an instance of
+[`ConnectionFactory`](https://rabbitmq.github.io/rabbitmq-java-client/api/current/com/rabbitmq/client/ConnectionFactory.html):
+
+``` java
+{{ insert('rabbitmq/og/customization/RabbitMQProducers.java', 'named') }}
+```
+
+This instance is retrieved and used to configure the client used by the
+connector. You need to indicate the name of the client using the
+`client-options-name` attribute:
+
+    mp.messaging.incoming.prices.client-options-name=my-named-options
+
+## Credentials Provider
+
+The OG connector supports RabbitMQ's
+[`CredentialsProvider`](https://rabbitmq.github.io/rabbitmq-java-client/api/current/com/rabbitmq/client/impl/CredentialsProvider.html)
+interface for dynamic credential management. This is useful when
+credentials are rotated or fetched from an external secrets manager.
+
+To use a credentials provider, expose a CDI bean implementing
+`com.rabbitmq.client.impl.CredentialsProvider` with an `@Identifier`
+qualifier, and reference it via the `credentials-provider-name` attribute:
+
+```properties
+mp.messaging.incoming.prices.credentials-provider-name=my-credentials-provider
+```
+
+## Cluster mode
+
+To connect to a RabbitMQ cluster, use the `addresses` attribute to
+specify multiple broker addresses. When set, this overrides the `host`
+and `port` attributes:
+
+```properties
+rabbitmq-addresses=host1:5672,host2:5672,host3:5672
+```
+
+## NIO Sockets
+
+The connector supports using NIO sockets for the RabbitMQ connection.
+Enable NIO mode with:
+
+```properties
+rabbitmq-use-nio=true
+```