ramu11 opened a new pull request, #25905:
URL: https://github.com/apache/camel/pull/25905
## CAMEL-23503: Add native HiveMQ component
### Description
This PR adds a new native `camel-hivemq` component to Apache Camel,
providing MQTT connectivity using the modern HiveMQ Java Client SDK.
While Camel already provides MQTT support through generic components such as
`camel-paho`, this component provides a dedicated HiveMQ-based implementation
with native Camel endpoint/configuration support and integration with Camel's
test infrastructure.
### Key capabilities
* Dedicated HiveMQ endpoint
* Adds the `hivemq:` endpoint for publishing messages to and consuming
messages from MQTT brokers.
* Supports broker connection configuration such as host, port,
credentials, and other MQTT client settings.
* QoS and retained message support
* Supports MQTT QoS levels including QoS 1 (`AT_LEAST_ONCE`) and QoS 2
(`EXACTLY_ONCE`).
* Supports MQTT retained messages through the `CamelHiveMQRetained` header.
* Camel test infrastructure integration
* Adds the `test-infra-hivemq` module integration.
* Uses Testcontainers and `HiveMQService` to start a real HiveMQ broker
for integration testing.
* Adds integration coverage for publish/subscribe, topic overrides, QoS,
retained messages, dynamic sends, and component configuration.
### Testing
Validated locally with:
mvn -pl components/camel-hivemq -am -DskipTests install
mvn -pl components/camel-hivemq -DskipITs test
mvn clean install -Psourcecheck -pl components/camel-hivemq -am
Results:
* Maven build: SUCCESS
* Tests: 4 passed, 0 failures, 0 errors
* `git diff --check`: clean
* `git diff --cached --check`: clean
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
