This is an automated email from the ASF dual-hosted git repository.
Croway pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 0a1251edfa2 CAMEL-26735: camel-vertx-mqtt-starter - add the Spring
Boot starter for the camel-vertx-mqtt component (#2083)
0a1251edfa2 is described below
commit 0a1251edfa2e0c7cba53c716d30ce1c451bbaf11
Author: Andreas Huber <[email protected]>
AuthorDate: Mon Nov 9 18:54:54 2026 +0100
CAMEL-26735: camel-vertx-mqtt-starter - add the Spring Boot starter for the
camel-vertx-mqtt component (#2083)
* CAMEL-26735: camel-vertx-mqtt-starter - add the Spring Boot starter for
the camel-vertx-mqtt component
By hand: the starter pom, LICENSE/NOTICE, a binding test and the
registration in components-starter,
the bom, camel-spring-boot-dependencies and the nav. The rest comes from
the generator plugin.
Co-Authored-By: Claude Opus 5.5 <[email protected]>
* CAMEL-26735: camel-vertx-mqtt-starter - add the integration test
CamelCatalogIT requires
Generated with mvn -Pgenerate -Dstarter=vertx-mqtt in
tests/camel-itest-spring-boot.
Co-Authored-By: Claude Opus 5.5 <[email protected]>
---------
Co-authored-by: Claude Opus 5.5 <[email protected]>
---
.../camel/springboot/catalog/components.properties | 1 +
.../springboot/catalog/components/vertx-mqtt.json | 107 +++++
.../camel-vertx-mqtt-starter/pom.xml | 48 ++
.../src/main/docs/vertx-mqtt.json | 247 +++++++++++
.../VertxMqttComponentAutoConfiguration.java | 74 ++++
.../VertxMqttComponentConfiguration.java | 487 +++++++++++++++++++++
.../springboot/VertxMqttComponentConverter.java | 56 +++
.../src/main/resources/META-INF/LICENSE.txt | 203 +++++++++
.../src/main/resources/META-INF/NOTICE.txt | 11 +
...rk.boot.autoconfigure.AutoConfiguration.imports | 18 +
.../VertxMqttComponentConfigurationTest.java | 59 +++
.../src/test/resources/application.properties | 17 +
components-starter/pom.xml | 1 +
docs/spring-boot/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/starters/vertx-mqtt.adoc | 64 +++
.../camel/itest/springboot/CamelVertxMqttIT.java | 28 ++
tooling/camel-spring-boot-bom/pom.xml | 5 +
tooling/camel-spring-boot-dependencies/pom.xml | 5 +
18 files changed, 1432 insertions(+)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
index f3694000414..9e6b8a309fd 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
@@ -396,6 +396,7 @@ validator
velocity
vertx
vertx-http
+vertx-mqtt
vertx-websocket
wasm
weather
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-mqtt.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-mqtt.json
new file mode 100644
index 00000000000..da6fb69cb0b
--- /dev/null
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/vertx-mqtt.json
@@ -0,0 +1,107 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "vertx-mqtt",
+ "title": "Vert.x MQTT",
+ "description": "Send and receive messages to and from an MQTT broker, MQTT
3.1.1 and 5, with the Vert.x MQTT client.",
+ "deprecated": false,
+ "firstVersion": "4.24.0",
+ "label": "messaging,iot",
+ "javaType": "org.apache.camel.component.vertx.mqtt.VertxMqttComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel.springboot",
+ "artifactId": "camel-vertx-mqtt-starter",
+ "version": "4.24.0-SNAPSHOT",
+ "scheme": "vertx-mqtt",
+ "extendsScheme": "",
+ "syntax": "vertx-mqtt:topic",
+ "async": false,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": false,
+ "lenientProperties": false,
+ "browsable": false,
+ "remote": true
+ },
+ "componentProperties": {
+ "automaticReconnect": { "index": 0, "kind": "property", "displayName":
"Automatic Reconnect", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the client
connects again when the connection is lost, and keeps trying [...]
+ "brokerUrl": { "index": 1, "kind": "property", "displayName": "Broker
Url", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "tcp:\/\/localhost:1883",
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The URL of the broker:
tcp:\/\/host:port or mqtt:\/\/host:port for a p [...]
+ "cleanStart": { "index": 2, "kind": "property", "displayName": "Clean
Start", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the broker
discards the session of the client when it connects, the clean session flag o
[...]
+ "clientId": { "index": 3, "kind": "property", "displayName": "Client Id",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The client identifier. A
random one is generated if none is set. A broker allows one connection per
client identif [...]
+ "configuration": { "index": 4, "kind": "property", "displayName":
"Configuration", "group": "common", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration", "deprecated":
false, "autowired": false, "secret": false, "description": "The shared
configuration of the endpoints." },
+ "keepAliveInterval": { "index": 5, "kind": "property", "displayName":
"Keep Alive Interval", "group": "common", "label": "", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The keep alive interval
in seconds. 0 switches keep alive off." },
+ "mqttVersion": { "index": 6, "kind": "property", "displayName": "Mqtt
Version", "group": "common", "label": "", "required": false, "type": "enum",
"javaType": "org.apache.camel.component.vertx.mqtt.VertxMqttVersion", "enum": [
"MQTT_3_1_1", "MQTT_5_0" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "MQTT_5_0", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The ve [...]
+ "qos": { "index": 7, "kind": "property", "displayName": "Qos", "group":
"common", "label": "", "required": false, "type": "enum", "javaType": "int",
"enum": [ "0", "1", "2" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The quality of service:
0 (at most once), 1 (at least once) or 2 (exactly once). For a consume [...]
+ "retained": { "index": 8, "kind": "property", "displayName": "Retained",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the broker
retains a published message for subscribers that arrive later." },
+ "sessionExpiryInterval": { "index": 9, "kind": "property", "displayName":
"Session Expiry Interval", "group": "common", "label": "", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "MQTT 5 only. How long
the broker keeps the session after the connection closed, [...]
+ "bridgeErrorHandler": { "index": 10, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions (if possible) occurred while the Camel consumer is trying
to pickup incoming messages, or the lik [...]
+ "manualAcksEnabled": { "index": 11, "kind": "property", "displayName":
"Manual Acks Enabled", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether a message of
quality of service 1 or 2 is acknowledged only o [...]
+ "receiveMaximum": { "index": 12, "kind": "property", "displayName":
"Receive Maximum", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "MQTT 5 only. The most
messages of quality of service 1 and 2 the broker sends before [...]
+ "maxPendingMessages": { "index": 13, "kind": "property", "displayName":
"Max Pending Messages", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The most received
messages waiting for their exchang [...]
+ "ackTimeout": { "index": 14, "kind": "property", "displayName": "Ack
Timeout", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "How long a message of
quality of service 1 or 2 waits for its acknowledgement, in seconds. [...]
+ "lazyStartProducer": { "index": 15, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fai [...]
+ "maxInflightQueue": { "index": 16, "kind": "property", "displayName": "Max
Inflight Queue", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The most messages of
quality of service 1 and 2 the client has sent without an [...]
+ "autowiredEnabled": { "index": 17, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
+ "connectTimeout": { "index": 18, "kind": "property", "displayName":
"Connect Timeout", "group": "advanced", "label": "advanced", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "30000", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "How long to wait for the
connection to the broker, in milliseconds." },
+ "maxMessageSize": { "index": 19, "kind": "property", "displayName": "Max
Message Size", "group": "advanced", "label": "advanced", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 268435455, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The largest message in
bytes the client receives, the protocol maximum by d [...]
+ "maxReconnectDelay": { "index": 20, "kind": "property", "displayName":
"Max Reconnect Delay", "group": "advanced", "label": "advanced", "required":
false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "60000",
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The longest delay
between two attempts to reconnect, in milliseconds." },
+ "reconnectDelay": { "index": 21, "kind": "property", "displayName":
"Reconnect Delay", "group": "advanced", "label": "advanced", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1000", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The delay before the
first attempt to reconnect, in milliseconds. Every furth [...]
+ "vertx": { "index": 22, "kind": "property", "displayName": "Vertx",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "io.vertx.core.Vertx", "deprecated": false, "autowired": true,
"secret": false, "description": "The Vert.x instance to use. Without, the one
of the registry if there is exactly one, else a Vert.x instance of the
component's own, closed when the component stops." },
+ "vertxOptions": { "index": 23, "kind": "property", "displayName": "Vertx
Options", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "io.vertx.core.VertxOptions", "deprecated": false,
"autowired": false, "secret": false, "description": "The options of the Vert.x
instance the component creates when none is given." },
+ "willPayload": { "index": 24, "kind": "property", "displayName": "Will
Payload", "group": "advanced", "label": "advanced", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The payload of the will
message." },
+ "willQos": { "index": 25, "kind": "property", "displayName": "Will Qos",
"group": "advanced", "label": "advanced", "required": false, "type": "enum",
"javaType": "int", "enum": [ "0", "1", "2" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The quality of service
of the will message." },
+ "willRetained": { "index": 26, "kind": "property", "displayName": "Will
Retained", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the will message
is retained." },
+ "willTopic": { "index": 27, "kind": "property", "displayName": "Will
Topic", "group": "advanced", "label": "advanced", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The topic of the will
message the broker publishes when the client goes away without disconnecting."
},
+ "password": { "index": 28, "kind": "property", "displayName": "Password",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "security": "secret", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The password to
authenticate with." },
+ "sslContextParameters": { "index": 29, "kind": "property", "displayName":
"Ssl Context Parameters", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The TLS configuration
[...]
+ "useGlobalSslContextParameters": { "index": 30, "kind": "property",
"displayName": "Use Global Ssl Context Parameters", "group": "security",
"label": "security", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether to use the global SSL context
parameters of the Camel context for an endpoint that sets none." },
+ "username": { "index": 31, "kind": "property", "displayName": "Username",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "security": "secret", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The user name to
authenticate with." }
+ },
+ "headers": {
+ "CamelVertxMqttTopic": { "index": 0, "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The topic the message was published on.",
"constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#TOPIC" },
+ "CamelVertxMqttQos": { "index": 1, "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"Integer", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The quality of service the message was
delivered with: 0, 1 or 2.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#QOS" },
+ "CamelVertxMqttRetained": { "index": 2, "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"Boolean", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Whether the broker delivered a retained
message.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#RETAINED" },
+ "CamelVertxMqttDuplicate": { "index": 3, "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"Boolean", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Whether the broker delivers the message
again.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#DUPLICATE" },
+ "CamelVertxMqttMessageId": { "index": 4, "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"Integer", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The packet identifier of a message of quality
of service 1 or 2.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#MESSAGE_ID" },
+ "CamelVertxMqttOverrideTopic": { "index": 5, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The topic to publish on instead of the
topic of the endpoint.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#OVERRIDE_TOPIC" },
+ "CamelVertxMqttOverrideQos": { "index": 6, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The quality of service to publish with
instead of the qos option of the endpoint: 0, 1 or 2.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#OVERRIDE_QOS" },
+ "CamelVertxMqttOverrideRetained": { "index": 7, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Whether to publish the message as
retained, instead of the retained option of the endpoint.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#OVERRIDE_RETAINED" },
+ "CamelVertxMqttUserProperties": { "index": 8, "kind": "header",
"displayName": "", "group": "common", "label": "", "required": false,
"javaType": "java.util.List<java.util.Map.Entry<String, String>>",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "MQTT 5 only. The user properties of the message, in
their order and with keys that occur more than once. The producer also takes a
Map.", "constantName": "org.apache.camel.component.vertx.mq [...]
+ "CamelVertxMqttContentType": { "index": 9, "kind": "header",
"displayName": "", "group": "common", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "MQTT 5 only. The content type of the
message.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#CONTENT_TYPE" },
+ "CamelVertxMqttResponseTopic": { "index": 10, "kind": "header",
"displayName": "", "group": "common", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "MQTT 5 only. The topic a response is
expected on.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#RESPONSE_TOPIC" },
+ "CamelVertxMqttCorrelationData": { "index": 11, "kind": "header",
"displayName": "", "group": "common", "label": "", "required": false,
"javaType": "byte[]", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "MQTT 5 only. The data that relates a
response to its request.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#CORRELATION_DATA" },
+ "CamelVertxMqttMessageExpiryInterval": { "index": 12, "kind": "header",
"displayName": "", "group": "common", "label": "", "required": false,
"javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "MQTT 5 only. The lifetime of the
message in seconds.", "constantName":
"org.apache.camel.component.vertx.mqtt.VertxMqttConstants#MESSAGE_EXPIRY_INTERVAL"
}
+ },
+ "properties": {
+ "topic": { "index": 0, "kind": "path", "displayName": "Topic", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The topic to publish on, or the topic
filter to subscribe to. A filter may hold the wildcards + and #, a topic to
publish on may not." },
+ "automaticReconnect": { "index": 1, "kind": "parameter", "displayName":
"Automatic Reconnect", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the client
connects again when the connection is lost, and keeps trying [...]
+ "brokerUrl": { "index": 2, "kind": "parameter", "displayName": "Broker
Url", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "tcp:\/\/localhost:1883",
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The URL of the broker:
tcp:\/\/host:port or mqtt:\/\/host:port for a [...]
+ "cleanStart": { "index": 3, "kind": "parameter", "displayName": "Clean
Start", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the broker
discards the session of the client when it connects, the clean session flag
[...]
+ "clientId": { "index": 4, "kind": "parameter", "displayName": "Client Id",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The client identifier. A
random one is generated if none is set. A broker allows one connection per
client identi [...]
+ "keepAliveInterval": { "index": 5, "kind": "parameter", "displayName":
"Keep Alive Interval", "group": "common", "label": "", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The keep alive interval
in seconds. 0 switches keep alive off." },
+ "mqttVersion": { "index": 6, "kind": "parameter", "displayName": "Mqtt
Version", "group": "common", "label": "", "required": false, "type": "enum",
"javaType": "org.apache.camel.component.vertx.mqtt.VertxMqttVersion", "enum": [
"MQTT_3_1_1", "MQTT_5_0" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "MQTT_5_0", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The v [...]
+ "qos": { "index": 7, "kind": "parameter", "displayName": "Qos", "group":
"common", "label": "", "required": false, "type": "enum", "javaType": "int",
"enum": [ "0", "1", "2" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The quality of service:
0 (at most once), 1 (at least once) or 2 (exactly once). For a consum [...]
+ "retained": { "index": 8, "kind": "parameter", "displayName": "Retained",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the broker
retains a published message for subscribers that arrive later." },
+ "sessionExpiryInterval": { "index": 9, "kind": "parameter", "displayName":
"Session Expiry Interval", "group": "common", "label": "", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "MQTT 5 only. How long
the broker keeps the session after the connection closed [...]
+ "manualAcksEnabled": { "index": 10, "kind": "parameter", "displayName":
"Manual Acks Enabled", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether a message of
quality of service 1 or 2 is acknowledged only [...]
+ "receiveMaximum": { "index": 11, "kind": "parameter", "displayName":
"Receive Maximum", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "MQTT 5 only. The most
messages of quality of service 1 and 2 the broker sends befor [...]
+ "bridgeErrorHandler": { "index": 12, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
+ "exceptionHandler": { "index": 13, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By de [...]
+ "exchangePattern": { "index": 14, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "enum", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
+ "maxPendingMessages": { "index": 15, "kind": "parameter", "displayName":
"Max Pending Messages", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The most received
messages waiting for their exchan [...]
+ "ackTimeout": { "index": 16, "kind": "parameter", "displayName": "Ack
Timeout", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "How long a message of
quality of service 1 or 2 waits for its acknowledgement, in seconds. [...]
+ "maxInflightQueue": { "index": 17, "kind": "parameter", "displayName":
"Max Inflight Queue", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The most messages of
quality of service 1 and 2 the client has sent without a [...]
+ "lazyStartProducer": { "index": 18, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "connectTimeout": { "index": 19, "kind": "parameter", "displayName":
"Connect Timeout", "group": "advanced", "label": "advanced", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "30000", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "How long to wait for the
connection to the broker, in milliseconds." },
+ "maxMessageSize": { "index": 20, "kind": "parameter", "displayName": "Max
Message Size", "group": "advanced", "label": "advanced", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 268435455, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The largest message in
bytes the client receives, the protocol maximum by [...]
+ "maxReconnectDelay": { "index": 21, "kind": "parameter", "displayName":
"Max Reconnect Delay", "group": "advanced", "label": "advanced", "required":
false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "60000",
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The longest delay
between two attempts to reconnect, in milliseconds." },
+ "reconnectDelay": { "index": 22, "kind": "parameter", "displayName":
"Reconnect Delay", "group": "advanced", "label": "advanced", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1000", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The delay before the
first attempt to reconnect, in milliseconds. Every furt [...]
+ "willPayload": { "index": 23, "kind": "parameter", "displayName": "Will
Payload", "group": "advanced", "label": "advanced", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The payload of the will
message." },
+ "willQos": { "index": 24, "kind": "parameter", "displayName": "Will Qos",
"group": "advanced", "label": "advanced", "required": false, "type": "enum",
"javaType": "int", "enum": [ "0", "1", "2" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The quality of service
of the will message." },
+ "willRetained": { "index": 25, "kind": "parameter", "displayName": "Will
Retained", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "Whether the will message
is retained." },
+ "willTopic": { "index": 26, "kind": "parameter", "displayName": "Will
Topic", "group": "advanced", "label": "advanced", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The topic of the will
message the broker publishes when the client goes away without disconnecting."
},
+ "password": { "index": 27, "kind": "parameter", "displayName": "Password",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "security": "secret", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The password to
authenticate with." },
+ "sslContextParameters": { "index": 28, "kind": "parameter", "displayName":
"Ssl Context Parameters", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The TLS configuratio
[...]
+ "username": { "index": 29, "kind": "parameter", "displayName": "Username",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "security": "secret", "configurationClass":
"org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
"configurationField": "configuration", "description": "The user name to
authenticate with." }
+ }
+}
diff --git a/components-starter/camel-vertx-mqtt-starter/pom.xml
b/components-starter/camel-vertx-mqtt-starter/pom.xml
new file mode 100644
index 00000000000..2a3ded05476
--- /dev/null
+++ b/components-starter/camel-vertx-mqtt-starter/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>components-starter</artifactId>
+ <version>4.24.0-SNAPSHOT</version>
+ </parent>
+ <artifactId>camel-vertx-mqtt-starter</artifactId>
+ <packaging>jar</packaging>
+ <name>Camel SB Starters :: Vert.x MQTT</name>
+ <dependencies>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter</artifactId>
+ <version>${spring-boot-version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-vertx-mqtt</artifactId>
+ <version>${camel-version}</version>
+ </dependency>
+ <!--START OF GENERATED CODE-->
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-core-starter</artifactId>
+ </dependency>
+ <!--END OF GENERATED CODE-->
+ </dependencies>
+</project>
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/docs/vertx-mqtt.json
b/components-starter/camel-vertx-mqtt-starter/src/main/docs/vertx-mqtt.json
new file mode 100644
index 00000000000..7a44fa6462c
--- /dev/null
+++ b/components-starter/camel-vertx-mqtt-starter/src/main/docs/vertx-mqtt.json
@@ -0,0 +1,247 @@
+{
+ "groups": [
+ {
+ "name": "camel.component.vertx-mqtt",
+ "type":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.customizer",
+ "type":
"org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon$CustomizerProperties",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "sourceMethod": "getCustomizer()"
+ }
+ ],
+ "properties": [
+ {
+ "name": "camel.component.vertx-mqtt.ack-timeout",
+ "type": "java.lang.Integer",
+ "description": "How long a message of quality of service 1 or 2 waits
for its acknowledgement, in seconds. The exchange fails when the time is up. 0
or less waits without a limit.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 30
+ },
+ {
+ "name": "camel.component.vertx-mqtt.automatic-reconnect",
+ "type": "java.lang.Boolean",
+ "description": "Whether the client connects again when the connection is
lost, and keeps trying when the first connection fails. Without, a failed first
connection fails the start of the route.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": true
+ },
+ {
+ "name": "camel.component.vertx-mqtt.autowired-enabled",
+ "type": "java.lang.Boolean",
+ "description": "Whether autowiring is enabled. This is used for
automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": true
+ },
+ {
+ "name": "camel.component.vertx-mqtt.bridge-error-handler",
+ "type": "java.lang.Boolean",
+ "description": "Allows for bridging the consumer to the Camel routing
Error Handler, which mean any exceptions (if possible) occurred while the Camel
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. Important:
This is only possible if the 3rd party component allows Camel to be alerted if
an exception was thrown. Some components handle this internally only, and
therefore bridgeErrorHandler is n [...]
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.vertx-mqtt.broker-url",
+ "type": "java.lang.String",
+ "description": "The URL of the broker: tcp:\/\/host:port or
mqtt:\/\/host:port for a plain connection, ssl:\/\/host:port or
mqtts:\/\/host:port for TLS. Without a port 1883 is used for a plain connection
and 8883 for TLS.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": "tcp:\/\/localhost:1883"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.clean-start",
+ "type": "java.lang.Boolean",
+ "description": "Whether the broker discards the session of the client
when it connects, the clean session flag of MQTT 3.1.1.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": true
+ },
+ {
+ "name": "camel.component.vertx-mqtt.client-id",
+ "type": "java.lang.String",
+ "description": "The client identifier. A random one is generated if none
is set. A broker allows one connection per client identifier, so two endpoints
must not share one.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.configuration",
+ "type": "org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration",
+ "description": "The shared configuration of the endpoints. The option is
a org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.connect-timeout",
+ "type": "java.lang.Long",
+ "description": "How long to wait for the connection to the broker, in
milliseconds. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 30000
+ },
+ {
+ "name": "camel.component.vertx-mqtt.customizer.enabled",
+ "type": "java.lang.Boolean",
+ "sourceType":
"org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon$CustomizerProperties"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.enabled",
+ "type": "java.lang.Boolean",
+ "description": "Whether to enable auto configuration of the vertx-mqtt
component. This is enabled by default.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.keep-alive-interval",
+ "type": "java.lang.Integer",
+ "description": "The keep alive interval in seconds. 0 switches keep
alive off.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 30
+ },
+ {
+ "name": "camel.component.vertx-mqtt.lazy-start-producer",
+ "type": "java.lang.Boolean",
+ "description": "Whether the producer should be started lazy (on the
first message). By starting lazy you can use this to allow CamelContext and
routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and starting the [...]
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.vertx-mqtt.manual-acks-enabled",
+ "type": "java.lang.Boolean",
+ "description": "Whether a message of quality of service 1 or 2 is
acknowledged only once its exchange completed successfully. Otherwise the
client acknowledges it as soon as it arrives.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.vertx-mqtt.max-inflight-queue",
+ "type": "java.lang.Integer",
+ "description": "The most messages of quality of service 1 and 2 the
client has sent without an acknowledgement. A message beyond it fails.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 10
+ },
+ {
+ "name": "camel.component.vertx-mqtt.max-message-size",
+ "type": "java.lang.Integer",
+ "description": "The largest message in bytes the client receives, the
protocol maximum by default. Every message is read into memory as a whole, so
lower it for a broker whose publishers are not trusted.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 268435455
+ },
+ {
+ "name": "camel.component.vertx-mqtt.max-pending-messages",
+ "type": "java.lang.Integer",
+ "description": "The most received messages waiting for their exchange to
complete. Beyond it the client stops reading from the connection until the
consumer caught up, which holds back the broker for every quality of service.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 1000
+ },
+ {
+ "name": "camel.component.vertx-mqtt.max-reconnect-delay",
+ "type": "java.lang.Long",
+ "description": "The longest delay between two attempts to reconnect, in
milliseconds. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 60000
+ },
+ {
+ "name": "camel.component.vertx-mqtt.mqtt-version",
+ "type": "org.apache.camel.component.vertx.mqtt.VertxMqttVersion",
+ "description": "The version of the MQTT protocol.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": "mqtt-5-0"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.password",
+ "type": "java.lang.String",
+ "description": "The password to authenticate with.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.qos",
+ "type": "java.lang.Integer",
+ "description": "The quality of service: 0 (at most once), 1 (at least
once) or 2 (exactly once). For a consumer the maximum quality of service of its
subscription.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 1
+ },
+ {
+ "name": "camel.component.vertx-mqtt.receive-maximum",
+ "type": "java.lang.Integer",
+ "description": "MQTT 5 only. The most messages of quality of service 1
and 2 the broker sends before the client acknowledges them. 0 leaves it to the
broker.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 0
+ },
+ {
+ "name": "camel.component.vertx-mqtt.reconnect-delay",
+ "type": "java.lang.Long",
+ "description": "The delay before the first attempt to reconnect, in
milliseconds. Every further attempt doubles it, up to the maximum reconnect
delay. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 1000
+ },
+ {
+ "name": "camel.component.vertx-mqtt.retained",
+ "type": "java.lang.Boolean",
+ "description": "Whether the broker retains a published message for
subscribers that arrive later.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.vertx-mqtt.session-expiry-interval",
+ "type": "java.lang.Long",
+ "description": "MQTT 5 only. How long the broker keeps the session after
the connection closed, in seconds. 0 ends it with the connection.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 0
+ },
+ {
+ "name": "camel.component.vertx-mqtt.ssl-context-parameters",
+ "type": "org.apache.camel.support.jsse.SSLContextParameters",
+ "description": "The TLS configuration of a connection to an ssl:\/\/ or
mqtts:\/\/ broker: key managers for a client certificate, trust managers,
protocols and cipher suites. Without it the trust store of the JVM is used. The
host name of the broker is always verified against its certificate: there is
intentionally no option to switch the check off. The option is a
org.apache.camel.support.jsse.SSLContextParameters type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.use-global-ssl-context-parameters",
+ "type": "java.lang.Boolean",
+ "description": "Whether to use the global SSL context parameters of the
Camel context for an endpoint that sets none.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.vertx-mqtt.username",
+ "type": "java.lang.String",
+ "description": "The user name to authenticate with.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.vertx",
+ "type": "io.vertx.core.Vertx",
+ "description": "The Vert.x instance to use. Without, the one of the
registry if there is exactly one, else a Vert.x instance of the component's
own, closed when the component stops. The option is a io.vertx.core.Vertx
type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.vertx-options",
+ "type": "io.vertx.core.VertxOptions",
+ "description": "The options of the Vert.x instance the component creates
when none is given. The option is a io.vertx.core.VertxOptions type.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.will-payload",
+ "type": "java.lang.String",
+ "description": "The payload of the will message.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ },
+ {
+ "name": "camel.component.vertx-mqtt.will-qos",
+ "type": "java.lang.Integer",
+ "description": "The quality of service of the will message.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": 0
+ },
+ {
+ "name": "camel.component.vertx-mqtt.will-retained",
+ "type": "java.lang.Boolean",
+ "description": "Whether the will message is retained.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.vertx-mqtt.will-topic",
+ "type": "java.lang.String",
+ "description": "The topic of the will message the broker publishes when
the client goes away without disconnecting.",
+ "sourceType":
"org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration"
+ }
+ ],
+ "hints": [],
+ "ignored": {
+ "properties": []
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentAutoConfiguration.java
b/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentAutoConfiguration.java
new file mode 100644
index 00000000000..a510399c985
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentAutoConfiguration.java
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.vertx.mqtt.springboot;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.Component;
+import org.apache.camel.component.vertx.mqtt.VertxMqttComponent;
+import org.apache.camel.spi.ComponentCustomizer;
+import org.apache.camel.spring.boot.CamelAutoConfiguration;
+import org.apache.camel.spring.boot.ComponentConfigurationProperties;
+import org.apache.camel.spring.boot.util.CamelPropertiesHelper;
+import
org.apache.camel.spring.boot.util.ConditionalOnCamelContextAndAutoConfigurationBeans;
+import org.apache.camel.spring.boot.util.ConditionalOnHierarchicalProperties;
+import org.apache.camel.spring.boot.util.HierarchicalPropertiesEvaluator;
+import org.springframework.boot.autoconfigure.AutoConfiguration;
+import
org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Conditional;
+import org.springframework.context.annotation.Lazy;
+
+/**
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@AutoConfiguration(after = {CamelAutoConfiguration.class,
VertxMqttComponentConverter.class})
+@Conditional(ConditionalOnCamelContextAndAutoConfigurationBeans.class)
+@EnableConfigurationProperties({ComponentConfigurationProperties.class,VertxMqttComponentConfiguration.class})
+@ConditionalOnHierarchicalProperties({"camel.component",
"camel.component.vertx-mqtt"})
+public class VertxMqttComponentAutoConfiguration {
+
+ private final ApplicationContext applicationContext;
+ private final VertxMqttComponentConfiguration configuration;
+
+ public VertxMqttComponentAutoConfiguration(
+ org.springframework.context.ApplicationContext applicationContext,
+
org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConfiguration
configuration) {
+ this.applicationContext = applicationContext;
+ this.configuration = configuration;
+ }
+
+ @Lazy
+ @Bean
+ public ComponentCustomizer configureVertxMqttComponent() {
+ return new ComponentCustomizer() {
+ @Override
+ public void configure(String name, Component target) {
+
CamelPropertiesHelper.copyConfigurationProperties(target.getCamelContext(),
applicationContext,
+ "camel.component.vertx-mqtt", configuration, target);
+ }
+ @Override
+ public boolean isEnabled(String name, Component target) {
+ return HierarchicalPropertiesEvaluator.evaluate(
+ applicationContext,
+ "camel.component.customizer",
+ "camel.component.vertx-mqtt.customizer")
+ && target instanceof VertxMqttComponent;
+ }
+ };
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConfiguration.java
b/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConfiguration.java
new file mode 100644
index 00000000000..585e50113ae
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConfiguration.java
@@ -0,0 +1,487 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.vertx.mqtt.springboot;
+
+import io.vertx.core.Vertx;
+import io.vertx.core.VertxOptions;
+import org.apache.camel.component.vertx.mqtt.VertxMqttComponent;
+import org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration;
+import org.apache.camel.component.vertx.mqtt.VertxMqttVersion;
+import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
+import org.apache.camel.support.jsse.SSLContextParameters;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * Send and receive messages to and from an MQTT broker, MQTT 3.1.1 and 5, with
+ * the Vert.x MQTT client.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@ConfigurationProperties(prefix = "camel.component.vertx-mqtt")
+public class VertxMqttComponentConfiguration
+ extends
+ ComponentConfigurationPropertiesCommon {
+
+ /**
+ * Whether to enable auto configuration of the vertx-mqtt component. This
is
+ * enabled by default.
+ */
+ private Boolean enabled;
+ /**
+ * Whether the client connects again when the connection is lost, and keeps
+ * trying when the first connection fails. Without, a failed first
+ * connection fails the start of the route.
+ */
+ private Boolean automaticReconnect = true;
+ /**
+ * The URL of the broker: tcp://host:port or mqtt://host:port for a plain
+ * connection, ssl://host:port or mqtts://host:port for TLS. Without a port
+ * 1883 is used for a plain connection and 8883 for TLS.
+ */
+ private String brokerUrl = "tcp://localhost:1883";
+ /**
+ * Whether the broker discards the session of the client when it connects,
+ * the clean session flag of MQTT 3.1.1.
+ */
+ private Boolean cleanStart = true;
+ /**
+ * The client identifier. A random one is generated if none is set. A
broker
+ * allows one connection per client identifier, so two endpoints must not
+ * share one.
+ */
+ private String clientId;
+ /**
+ * The shared configuration of the endpoints. The option is a
+ * org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration type.
+ */
+ private VertxMqttConfiguration configuration;
+ /**
+ * The keep alive interval in seconds. 0 switches keep alive off.
+ */
+ private Integer keepAliveInterval = 30;
+ /**
+ * The version of the MQTT protocol.
+ */
+ private VertxMqttVersion mqttVersion = VertxMqttVersion.MQTT_5_0;
+ /**
+ * The quality of service: 0 (at most once), 1 (at least once) or 2
(exactly
+ * once). For a consumer the maximum quality of service of its
subscription.
+ */
+ private Integer qos = 1;
+ /**
+ * Whether the broker retains a published message for subscribers that
+ * arrive later.
+ */
+ private Boolean retained = false;
+ /**
+ * MQTT 5 only. How long the broker keeps the session after the connection
+ * closed, in seconds. 0 ends it with the connection.
+ */
+ private Long sessionExpiryInterval = 0L;
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions (if possible) occurred while the Camel
consumer
+ * is trying to pickup incoming messages, or the likes, will now be
+ * processed as a message and handled by the routing Error Handler.
+ * Important: This is only possible if the 3rd party component allows Camel
+ * to be alerted if an exception was thrown. Some components handle this
+ * internally only, and therefore bridgeErrorHandler is not possible. In
+ * other situations we may improve the Camel component to hook into the 3rd
+ * party component and make this possible for future releases. By default
+ * the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and ignored.
+ */
+ private Boolean bridgeErrorHandler = false;
+ /**
+ * Whether a message of quality of service 1 or 2 is acknowledged only once
+ * its exchange completed successfully. Otherwise the client acknowledges
it
+ * as soon as it arrives.
+ */
+ private Boolean manualAcksEnabled = false;
+ /**
+ * MQTT 5 only. The most messages of quality of service 1 and 2 the broker
+ * sends before the client acknowledges them. 0 leaves it to the broker.
+ */
+ private Integer receiveMaximum = 0;
+ /**
+ * The most received messages waiting for their exchange to complete.
Beyond
+ * it the client stops reading from the connection until the consumer
caught
+ * up, which holds back the broker for every quality of service.
+ */
+ private Integer maxPendingMessages = 1000;
+ /**
+ * How long a message of quality of service 1 or 2 waits for its
+ * acknowledgement, in seconds. The exchange fails when the time is up. 0
or
+ * less waits without a limit.
+ */
+ private Integer ackTimeout = 30;
+ /**
+ * Whether the producer should be started lazy (on the first message). By
+ * starting lazy you can use this to allow CamelContext and routes to
+ * startup in situations where a producer may otherwise fail during
starting
+ * and cause the route to fail being started. By deferring this startup to
+ * be lazy then the startup failure can be handled during routing messages
+ * via Camel's routing error handlers. Beware that when the first message
is
+ * processed then creating and starting the producer may take a little time
+ * and prolong the total processing time of the processing.
+ */
+ private Boolean lazyStartProducer = false;
+ /**
+ * The most messages of quality of service 1 and 2 the client has sent
+ * without an acknowledgement. A message beyond it fails.
+ */
+ private Integer maxInflightQueue = 10;
+ /**
+ * Whether autowiring is enabled. This is used for automatic autowiring
+ * options (the option must be marked as autowired) by looking up in the
+ * registry to find if there is a single instance of matching type, which
+ * then gets configured on the component. This can be used for automatic
+ * configuring JDBC data sources, JMS connection factories, AWS Clients,
+ * etc.
+ */
+ private Boolean autowiredEnabled = true;
+ /**
+ * How long to wait for the connection to the broker, in milliseconds. The
+ * option is a long type.
+ */
+ private Long connectTimeout = 30000L;
+ /**
+ * The largest message in bytes the client receives, the protocol maximum
by
+ * default. Every message is read into memory as a whole, so lower it for a
+ * broker whose publishers are not trusted.
+ */
+ private Integer maxMessageSize = 268435455;
+ /**
+ * The longest delay between two attempts to reconnect, in milliseconds.
The
+ * option is a long type.
+ */
+ private Long maxReconnectDelay = 60000L;
+ /**
+ * The delay before the first attempt to reconnect, in milliseconds. Every
+ * further attempt doubles it, up to the maximum reconnect delay. The
option
+ * is a long type.
+ */
+ private Long reconnectDelay = 1000L;
+ /**
+ * The Vert.x instance to use. Without, the one of the registry if there is
+ * exactly one, else a Vert.x instance of the component's own, closed when
+ * the component stops. The option is a io.vertx.core.Vertx type.
+ */
+ private Vertx vertx;
+ /**
+ * The options of the Vert.x instance the component creates when none is
+ * given. The option is a io.vertx.core.VertxOptions type.
+ */
+ private VertxOptions vertxOptions;
+ /**
+ * The payload of the will message.
+ */
+ private String willPayload;
+ /**
+ * The quality of service of the will message.
+ */
+ private Integer willQos = 0;
+ /**
+ * Whether the will message is retained.
+ */
+ private Boolean willRetained = false;
+ /**
+ * The topic of the will message the broker publishes when the client goes
+ * away without disconnecting.
+ */
+ private String willTopic;
+ /**
+ * The password to authenticate with.
+ */
+ private String password;
+ /**
+ * The TLS configuration of a connection to an ssl:// or mqtts:// broker:
+ * key managers for a client certificate, trust managers, protocols and
+ * cipher suites. Without it the trust store of the JVM is used. The host
+ * name of the broker is always verified against its certificate: there is
+ * intentionally no option to switch the check off. The option is a
+ * org.apache.camel.support.jsse.SSLContextParameters type.
+ */
+ private SSLContextParameters sslContextParameters;
+ /**
+ * Whether to use the global SSL context parameters of the Camel context
for
+ * an endpoint that sets none.
+ */
+ private Boolean useGlobalSslContextParameters = false;
+ /**
+ * The user name to authenticate with.
+ */
+ private String username;
+
+ public Boolean getAutomaticReconnect() {
+ return automaticReconnect;
+ }
+
+ public void setAutomaticReconnect(Boolean automaticReconnect) {
+ this.automaticReconnect = automaticReconnect;
+ }
+
+ public String getBrokerUrl() {
+ return brokerUrl;
+ }
+
+ public void setBrokerUrl(String brokerUrl) {
+ this.brokerUrl = brokerUrl;
+ }
+
+ public Boolean getCleanStart() {
+ return cleanStart;
+ }
+
+ public void setCleanStart(Boolean cleanStart) {
+ this.cleanStart = cleanStart;
+ }
+
+ public String getClientId() {
+ return clientId;
+ }
+
+ public void setClientId(String clientId) {
+ this.clientId = clientId;
+ }
+
+ public VertxMqttConfiguration getConfiguration() {
+ return configuration;
+ }
+
+ public void setConfiguration(VertxMqttConfiguration configuration) {
+ this.configuration = configuration;
+ }
+
+ public Integer getKeepAliveInterval() {
+ return keepAliveInterval;
+ }
+
+ public void setKeepAliveInterval(Integer keepAliveInterval) {
+ this.keepAliveInterval = keepAliveInterval;
+ }
+
+ public VertxMqttVersion getMqttVersion() {
+ return mqttVersion;
+ }
+
+ public void setMqttVersion(VertxMqttVersion mqttVersion) {
+ this.mqttVersion = mqttVersion;
+ }
+
+ public Integer getQos() {
+ return qos;
+ }
+
+ public void setQos(Integer qos) {
+ this.qos = qos;
+ }
+
+ public Boolean getRetained() {
+ return retained;
+ }
+
+ public void setRetained(Boolean retained) {
+ this.retained = retained;
+ }
+
+ public Long getSessionExpiryInterval() {
+ return sessionExpiryInterval;
+ }
+
+ public void setSessionExpiryInterval(Long sessionExpiryInterval) {
+ this.sessionExpiryInterval = sessionExpiryInterval;
+ }
+
+ public Boolean getBridgeErrorHandler() {
+ return bridgeErrorHandler;
+ }
+
+ public void setBridgeErrorHandler(Boolean bridgeErrorHandler) {
+ this.bridgeErrorHandler = bridgeErrorHandler;
+ }
+
+ public Boolean getManualAcksEnabled() {
+ return manualAcksEnabled;
+ }
+
+ public void setManualAcksEnabled(Boolean manualAcksEnabled) {
+ this.manualAcksEnabled = manualAcksEnabled;
+ }
+
+ public Integer getReceiveMaximum() {
+ return receiveMaximum;
+ }
+
+ public void setReceiveMaximum(Integer receiveMaximum) {
+ this.receiveMaximum = receiveMaximum;
+ }
+
+ public Integer getMaxPendingMessages() {
+ return maxPendingMessages;
+ }
+
+ public void setMaxPendingMessages(Integer maxPendingMessages) {
+ this.maxPendingMessages = maxPendingMessages;
+ }
+
+ public Integer getAckTimeout() {
+ return ackTimeout;
+ }
+
+ public void setAckTimeout(Integer ackTimeout) {
+ this.ackTimeout = ackTimeout;
+ }
+
+ public Boolean getLazyStartProducer() {
+ return lazyStartProducer;
+ }
+
+ public void setLazyStartProducer(Boolean lazyStartProducer) {
+ this.lazyStartProducer = lazyStartProducer;
+ }
+
+ public Integer getMaxInflightQueue() {
+ return maxInflightQueue;
+ }
+
+ public void setMaxInflightQueue(Integer maxInflightQueue) {
+ this.maxInflightQueue = maxInflightQueue;
+ }
+
+ public Boolean getAutowiredEnabled() {
+ return autowiredEnabled;
+ }
+
+ public void setAutowiredEnabled(Boolean autowiredEnabled) {
+ this.autowiredEnabled = autowiredEnabled;
+ }
+
+ public Long getConnectTimeout() {
+ return connectTimeout;
+ }
+
+ public void setConnectTimeout(Long connectTimeout) {
+ this.connectTimeout = connectTimeout;
+ }
+
+ public Integer getMaxMessageSize() {
+ return maxMessageSize;
+ }
+
+ public void setMaxMessageSize(Integer maxMessageSize) {
+ this.maxMessageSize = maxMessageSize;
+ }
+
+ public Long getMaxReconnectDelay() {
+ return maxReconnectDelay;
+ }
+
+ public void setMaxReconnectDelay(Long maxReconnectDelay) {
+ this.maxReconnectDelay = maxReconnectDelay;
+ }
+
+ public Long getReconnectDelay() {
+ return reconnectDelay;
+ }
+
+ public void setReconnectDelay(Long reconnectDelay) {
+ this.reconnectDelay = reconnectDelay;
+ }
+
+ public Vertx getVertx() {
+ return vertx;
+ }
+
+ public void setVertx(Vertx vertx) {
+ this.vertx = vertx;
+ }
+
+ public VertxOptions getVertxOptions() {
+ return vertxOptions;
+ }
+
+ public void setVertxOptions(VertxOptions vertxOptions) {
+ this.vertxOptions = vertxOptions;
+ }
+
+ public String getWillPayload() {
+ return willPayload;
+ }
+
+ public void setWillPayload(String willPayload) {
+ this.willPayload = willPayload;
+ }
+
+ public Integer getWillQos() {
+ return willQos;
+ }
+
+ public void setWillQos(Integer willQos) {
+ this.willQos = willQos;
+ }
+
+ public Boolean getWillRetained() {
+ return willRetained;
+ }
+
+ public void setWillRetained(Boolean willRetained) {
+ this.willRetained = willRetained;
+ }
+
+ public String getWillTopic() {
+ return willTopic;
+ }
+
+ public void setWillTopic(String willTopic) {
+ this.willTopic = willTopic;
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public SSLContextParameters getSslContextParameters() {
+ return sslContextParameters;
+ }
+
+ public void setSslContextParameters(
+ SSLContextParameters sslContextParameters) {
+ this.sslContextParameters = sslContextParameters;
+ }
+
+ public Boolean getUseGlobalSslContextParameters() {
+ return useGlobalSslContextParameters;
+ }
+
+ public void setUseGlobalSslContextParameters(
+ Boolean useGlobalSslContextParameters) {
+ this.useGlobalSslContextParameters = useGlobalSslContextParameters;
+ }
+
+ public String getUsername() {
+ return username;
+ }
+
+ public void setUsername(String username) {
+ this.username = username;
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConverter.java
b/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConverter.java
new file mode 100644
index 00000000000..9334534fd39
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/main/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConverter.java
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.vertx.mqtt.springboot;
+
+import java.util.LinkedHashSet;
+import java.util.Set;
+import org.apache.camel.spring.boot.util.BeanReferenceHelper;
+import org.springframework.beans.factory.annotation.Autowired;
+import
org.springframework.boot.context.properties.ConfigurationPropertiesBinding;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.convert.TypeDescriptor;
+import org.springframework.core.convert.converter.GenericConverter;
+import org.springframework.stereotype.Component;
+
+/**
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Configuration(proxyBeanMethods = false)
+@ConfigurationPropertiesBinding
+@Component
+public class VertxMqttComponentConverter implements GenericConverter {
+
+ @Autowired
+ private ApplicationContext applicationContext;
+
+ public Set<ConvertiblePair> getConvertibleTypes() {
+ Set<ConvertiblePair> answer = new LinkedHashSet<>();
+ answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration.class));
+ answer.add(new ConvertiblePair(String.class,
io.vertx.core.Vertx.class));
+ answer.add(new ConvertiblePair(String.class,
io.vertx.core.VertxOptions.class));
+ answer.add(new ConvertiblePair(String.class,
org.apache.camel.support.jsse.SSLContextParameters.class));
+ return answer;
+ }
+
+ public Object convert(
+ Object source,
+ TypeDescriptor sourceType,
+ TypeDescriptor targetType) {
+ return BeanReferenceHelper.resolveBeanReference(applicationContext,
source, targetType, "camel.component.vertx-mqtt");
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/LICENSE.txt
b/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/LICENSE.txt
new file mode 100644
index 00000000000..6b0b1270ff0
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/LICENSE.txt
@@ -0,0 +1,203 @@
+
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/NOTICE.txt
b/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/NOTICE.txt
new file mode 100644
index 00000000000..2e215bf2e6b
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/NOTICE.txt
@@ -0,0 +1,11 @@
+ =========================================================================
+ == NOTICE file corresponding to the section 4 d of ==
+ == the Apache License, Version 2.0, ==
+ == in this case for the Apache Camel distribution. ==
+ =========================================================================
+
+ This product includes software developed by
+ The Apache Software Foundation (http://www.apache.org/).
+
+ Please read the different LICENSE files present in the licenses directory of
+ this distribution.
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
b/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
new file mode 100644
index 00000000000..300fc25d978
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
@@ -0,0 +1,18 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentConverter
+org.apache.camel.component.vertx.mqtt.springboot.VertxMqttComponentAutoConfiguration
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/test/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConfigurationTest.java
b/components-starter/camel-vertx-mqtt-starter/src/test/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConfigurationTest.java
new file mode 100644
index 00000000000..3f802a74ff1
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/test/java/org/apache/camel/component/vertx/mqtt/springboot/VertxMqttComponentConfigurationTest.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.vertx.mqtt.springboot;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.component.vertx.mqtt.VertxMqttComponent;
+import org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration;
+import org.apache.camel.component.vertx.mqtt.VertxMqttVersion;
+import org.apache.camel.spring.boot.CamelAutoConfiguration;
+import org.apache.camel.test.spring.junit6.CamelSpringBootTest;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.annotation.DirtiesContext;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+/**
+ * The options of the component bind from the Spring Boot properties, a long
and an enum among them.
+ */
+@CamelSpringBootTest
+@DirtiesContext
+@SpringBootTest(classes = { CamelAutoConfiguration.class,
VertxMqttComponentAutoConfiguration.class },
+ properties = {
+
"camel.component.vertx-mqtt.broker-url=tcp://broker.example.com:1884",
+ "camel.component.vertx-mqtt.qos=2",
+ "camel.component.vertx-mqtt.mqtt-version=MQTT_3_1_1",
+ "camel.component.vertx-mqtt.reconnect-delay=250",
+
"camel.component.vertx-mqtt.session-expiry-interval=300" })
+public class VertxMqttComponentConfigurationTest {
+
+ @Autowired
+ private CamelContext camelContext;
+
+ @Test
+ void theOptionsBindFromTheProperties() {
+ final VertxMqttConfiguration configuration
+ = camelContext.getComponent("vertx-mqtt",
VertxMqttComponent.class).getConfiguration();
+ assertEquals("tcp://broker.example.com:1884",
configuration.getBrokerUrl());
+ assertEquals(2, configuration.getQos());
+ assertEquals(VertxMqttVersion.MQTT_3_1_1,
configuration.getMqttVersion());
+ assertEquals(250L, configuration.getReconnectDelay());
+ assertEquals(300L, configuration.getSessionExpiryInterval());
+ }
+}
diff --git
a/components-starter/camel-vertx-mqtt-starter/src/test/resources/application.properties
b/components-starter/camel-vertx-mqtt-starter/src/test/resources/application.properties
new file mode 100644
index 00000000000..420025891ae
--- /dev/null
+++
b/components-starter/camel-vertx-mqtt-starter/src/test/resources/application.properties
@@ -0,0 +1,17 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+spring.main.banner-mode = off
diff --git a/components-starter/pom.xml b/components-starter/pom.xml
index f2368229aa0..19be7e2ce6d 100644
--- a/components-starter/pom.xml
+++ b/components-starter/pom.xml
@@ -516,6 +516,7 @@
<module>camel-validator-starter</module>
<module>camel-velocity-starter</module>
<module>camel-vertx-http-starter</module>
+ <module>camel-vertx-mqtt-starter</module>
<module>camel-vertx-starter</module>
<module>camel-vertx-websocket-starter</module>
<module>camel-wasm-starter</module>
diff --git a/docs/spring-boot/modules/ROOT/nav.adoc
b/docs/spring-boot/modules/ROOT/nav.adoc
index 557fa8c2ca5..4a0a45f6dfc 100644
--- a/docs/spring-boot/modules/ROOT/nav.adoc
+++ b/docs/spring-boot/modules/ROOT/nav.adoc
@@ -417,6 +417,7 @@
** xref:starters/validator.adoc[Validator]
** xref:starters/velocity.adoc[Velocity]
** xref:starters/vertx-http.adoc[Vert.x HTTP Client]
+** xref:starters/vertx-mqtt.adoc[Vert.x MQTT]
** xref:starters/vertx-websocket.adoc[Vert.x WebSocket]
** xref:starters/vertx.adoc[Vert.x]
** xref:starters/wasm.adoc[Wasm]
diff --git a/docs/spring-boot/modules/ROOT/pages/starters/vertx-mqtt.adoc
b/docs/spring-boot/modules/ROOT/pages/starters/vertx-mqtt.adoc
new file mode 100644
index 00000000000..23b3f6c7e67
--- /dev/null
+++ b/docs/spring-boot/modules/ROOT/pages/starters/vertx-mqtt.adoc
@@ -0,0 +1,64 @@
+// Do not edit directly!
+// This file was generated by camel-spring-boot-generator-maven-plugin
+= Vert.x MQTT
+:artifactid: camel-vertx-mqtt-starter
+
+Send and receive messages to and from an MQTT broker, MQTT 3.1.1 and 5, with
the Vert.x MQTT client.
+
+== What's inside
+
+* xref:{csb-camel-components}::vertx-mqtt-component.adoc[Vert.x MQTT
component], URI syntax: `vertx-mqtt:topic`
+
+Please refer to the above links for usage and configuration details.
+
+== Maven coordinates
+
+[source,xml]
+----
+<dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-vertx-mqtt-starter</artifactId>
+</dependency>
+----
+
+== Spring Boot Auto-Configuration
+
+The starter supports 33 options, which are listed below.
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| camel.component.vertx-mqtt.ack-timeout | How long a message of quality of
service 1 or 2 waits for its acknowledgement, in seconds. The exchange fails
when the time is up. 0 or less waits without a limit. | 30 | Integer
+| camel.component.vertx-mqtt.automatic-reconnect | Whether the client connects
again when the connection is lost, and keeps trying when the first connection
fails. Without, a failed first connection fails the start of the route. | true
| Boolean
+| camel.component.vertx-mqtt.autowired-enabled | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | Boolean
+| camel.component.vertx-mqtt.bridge-error-handler | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions (if
possible) occurred while the Camel consumer is trying to pickup incoming
messages, or the likes, will now be processed as a message and handled by the
routing Error Handler. Important: This is only possible if the 3rd party
component allows Camel to be alerted if an exception was thrown. Some
components handle this internally only, and the [...]
+| camel.component.vertx-mqtt.broker-url | The URL of the broker:
tcp://host:port or mqtt://host:port for a plain connection, ssl://host:port or
mqtts://host:port for TLS. Without a port 1883 is used for a plain connection
and 8883 for TLS. | tcp://localhost:1883 | String
+| camel.component.vertx-mqtt.clean-start | Whether the broker discards the
session of the client when it connects, the clean session flag of MQTT 3.1.1. |
true | Boolean
+| camel.component.vertx-mqtt.client-id | The client identifier. A random one
is generated if none is set. A broker allows one connection per client
identifier, so two endpoints must not share one. | | String
+| camel.component.vertx-mqtt.configuration | The shared configuration of the
endpoints. The option is a
org.apache.camel.component.vertx.mqtt.VertxMqttConfiguration type. | |
VertxMqttConfiguration
+| camel.component.vertx-mqtt.connect-timeout | How long to wait for the
connection to the broker, in milliseconds. The option is a long type. | 30000 |
Long
+| camel.component.vertx-mqtt.enabled | Whether to enable auto configuration of
the vertx-mqtt component. This is enabled by default. | | Boolean
+| camel.component.vertx-mqtt.keep-alive-interval | The keep alive interval in
seconds. 0 switches keep alive off. | 30 | Integer
+| camel.component.vertx-mqtt.lazy-start-producer | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed t [...]
+| camel.component.vertx-mqtt.manual-acks-enabled | Whether a message of
quality of service 1 or 2 is acknowledged only once its exchange completed
successfully. Otherwise the client acknowledges it as soon as it arrives. |
false | Boolean
+| camel.component.vertx-mqtt.max-inflight-queue | The most messages of quality
of service 1 and 2 the client has sent without an acknowledgement. A message
beyond it fails. | 10 | Integer
+| camel.component.vertx-mqtt.max-message-size | The largest message in bytes
the client receives, the protocol maximum by default. Every message is read
into memory as a whole, so lower it for a broker whose publishers are not
trusted. | 268435455 | Integer
+| camel.component.vertx-mqtt.max-pending-messages | The most received messages
waiting for their exchange to complete. Beyond it the client stops reading from
the connection until the consumer caught up, which holds back the broker for
every quality of service. | 1000 | Integer
+| camel.component.vertx-mqtt.max-reconnect-delay | The longest delay between
two attempts to reconnect, in milliseconds. The option is a long type. | 60000
| Long
+| camel.component.vertx-mqtt.mqtt-version | The version of the MQTT protocol.
| mqtt-5-0 | VertxMqttVersion
+| camel.component.vertx-mqtt.password | The password to authenticate with. |
| String
+| camel.component.vertx-mqtt.qos | The quality of service: 0 (at most once), 1
(at least once) or 2 (exactly once). For a consumer the maximum quality of
service of its subscription. | 1 | Integer
+| camel.component.vertx-mqtt.receive-maximum | MQTT 5 only. The most messages
of quality of service 1 and 2 the broker sends before the client acknowledges
them. 0 leaves it to the broker. | 0 | Integer
+| camel.component.vertx-mqtt.reconnect-delay | The delay before the first
attempt to reconnect, in milliseconds. Every further attempt doubles it, up to
the maximum reconnect delay. The option is a long type. | 1000 | Long
+| camel.component.vertx-mqtt.retained | Whether the broker retains a published
message for subscribers that arrive later. | false | Boolean
+| camel.component.vertx-mqtt.session-expiry-interval | MQTT 5 only. How long
the broker keeps the session after the connection closed, in seconds. 0 ends it
with the connection. | 0 | Long
+| camel.component.vertx-mqtt.ssl-context-parameters | The TLS configuration of
a connection to an ssl:// or mqtts:// broker: key managers for a client
certificate, trust managers, protocols and cipher suites. Without it the trust
store of the JVM is used. The host name of the broker is always verified
against its certificate: there is intentionally no option to switch the check
off. The option is a org.apache.camel.support.jsse.SSLContextParameters type. |
| SSLContextParameters
+| camel.component.vertx-mqtt.use-global-ssl-context-parameters | Whether to
use the global SSL context parameters of the Camel context for an endpoint that
sets none. | false | Boolean
+| camel.component.vertx-mqtt.username | The user name to authenticate with. |
| String
+| camel.component.vertx-mqtt.vertx | The Vert.x instance to use. Without, the
one of the registry if there is exactly one, else a Vert.x instance of the
component's own, closed when the component stops. The option is a
io.vertx.core.Vertx type. | | Vertx
+| camel.component.vertx-mqtt.vertx-options | The options of the Vert.x
instance the component creates when none is given. The option is a
io.vertx.core.VertxOptions type. | | VertxOptions
+| camel.component.vertx-mqtt.will-payload | The payload of the will message. |
| String
+| camel.component.vertx-mqtt.will-qos | The quality of service of the will
message. | 0 | Integer
+| camel.component.vertx-mqtt.will-retained | Whether the will message is
retained. | false | Boolean
+| camel.component.vertx-mqtt.will-topic | The topic of the will message the
broker publishes when the client goes away without disconnecting. | | String
+|===
diff --git
a/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelVertxMqttIT.java
b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelVertxMqttIT.java
new file mode 100644
index 00000000000..42c11bf2f36
--- /dev/null
+++
b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelVertxMqttIT.java
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.itest.springboot;
+
+import
org.apache.camel.itest.springboot.common.AbstractSpringBootBaseTestSupport;
+import org.junit.jupiter.api.Test;
+
+public class CamelVertxMqttIT extends AbstractSpringBootBaseTestSupport {
+
+ @Test
+ void componentTest() {
+ assertComponent(inferComponentName(getClass()));
+ }
+}
diff --git a/tooling/camel-spring-boot-bom/pom.xml
b/tooling/camel-spring-boot-bom/pom.xml
index b7668cdef43..a2ea604d7b3 100644
--- a/tooling/camel-spring-boot-bom/pom.xml
+++ b/tooling/camel-spring-boot-bom/pom.xml
@@ -2148,6 +2148,11 @@
<artifactId>camel-vertx-http-starter</artifactId>
<version>4.24.0-SNAPSHOT</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-vertx-mqtt-starter</artifactId>
+ <version>4.24.0-SNAPSHOT</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-vertx-starter</artifactId>
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index a402b8bdd97..316ba01c313 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -2477,6 +2477,11 @@
<artifactId>camel-vertx-http-starter</artifactId>
<version>${project.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-vertx-mqtt-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-vertx-starter</artifactId>
