Switch to Vert.x 5 - #3492
Open
ozangunalp wants to merge 8 commits into
Open
Conversation
- Bump Vert.x from 4.x to 5.1.3 and smallrye-vertx-mutiny-clients to 4.0.0-beta2 - Migrate internal APIs: io.vertx.core.impl -> io.vertx.core.internal - Migrate context locals to ContextLocals/VertxContext APIs - Migrate executeBlocking to Vert.x 5 Future-based API - Adapt Kafka TransactionalProducerTest to blocking API (withTransactionAndAwait) - Set root context for OutgoingAmqpChannel - Fix context locals availability when Vertx instance is created - Migrate documentation snippets - Add OpenRewrite recipes for Vert.x migration
Replace the Vert.x RabbitMQ client based connector with a new implementation built on the RabbitMQ AMQP Java client library. - Rewrite IncomingRabbitMQChannel and OutgoingRabbitMQChannel using the RabbitMQ Java client with SenderProcessor for graceful shutdown - Add shared connection support across channels - Add lazy client connection mode - Add RabbitMQ request-reply implementation - Add MessageConverters for IncomingRabbitMQMessage - Make ack/nack idempotent - Remove the old vertx-rabbitmq based connector and rabbitmq-og module, consolidate into a single smallrye-reactive-messaging-rabbitmq module - Update CI to reference the consolidated module - Update documentation and examples
ozangunalp
force-pushed
the
vertx_5_mqtt_5
branch
2 times, most recently
from
August 10, 2026 13:30
c4e8a94 to
ef7f594
Compare
ozangunalp
force-pushed
the
vertx_5_mqtt_5
branch
from
August 10, 2026 13:49
ef7f594 to
0c1b4cb
Compare
- Upgrade MqttClientSession to MQTT v5: QoS 2 publish handshake, CONNACK server constraints, reason code propagation, session expiry - Add ReceivingMqttMessageMetadata and SendingMqttMessageMetadataBuilder for v5 message properties (content type, response topic, correlation data, user properties) - Add MqttClientSessionCustomizer CDI hook for enhanced authentication - Add SubscriptionOptions with subscription identifier support - Add Paho MQTT v5 test client dependency
ozangunalp
force-pushed
the
vertx_5_mqtt_5
branch
from
August 14, 2026 10:04
0c18cd1 to
4bef237
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
With MQTT v5 and a new RabbitMQ connector on top of rabbitmq amqp-client