You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2025/08/20 05:39:24 UTC
(camel) branch main updated: Manual ack changes for mqtt v3
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 3d0bab91460 Manual ack changes for mqtt v3
3d0bab91460 is described below
commit 3d0bab9146000d2b6b937007d4676cdc30d3577d
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 20 07:32:40 2025 +0200
Manual ack changes for mqtt v3
---
.../org/apache/camel/catalog/components/paho.json | 50 +++++++++++-----------
.../component/dsl/PahoComponentBuilderFactory.java | 21 +++++++++
.../endpoint/dsl/PahoEndpointBuilderFactory.java | 36 ++++++++++++++++
3 files changed, 83 insertions(+), 24 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/paho.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/paho.json
index bbef5503a4b..628b2380ca9 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/paho.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/paho.json
@@ -44,17 +44,18 @@
"willRetained": { "index": 17, "kind": "property", "displayName": "Will Retained", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Last Will and Testament (LWT) for the connection. In the event that this client unexpectedly [...]
"willTopic": { "index": 18, "kind": "property", "displayName": "Will Topic", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Last Will and Testament (LWT) for the connection. In the event that this client unexpectedly loses its connection [...]
"bridgeErrorHandler": { "index": 19, "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 [...]
- "lazyStartProducer": { "index": 20, "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 [...]
- "autowiredEnabled": { "index": 21, "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 [...]
- "client": { "index": 22, "kind": "property", "displayName": "Client", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.eclipse.paho.client.mqttv3.MqttClient", "deprecated": false, "autowired": false, "secret": false, "description": "To use a shared Paho client" },
- "customWebSocketHeaders": { "index": 23, "kind": "property", "displayName": "Custom Web Socket Headers", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Custom WebSocket Headers for the WebSocket Connection." },
- "executorServiceTimeout": { "index": 24, "kind": "property", "displayName": "Executor Service Timeout", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Set the time in seconds that the executor service should wait when terminating [...]
- "httpsHostnameVerificationEnabled": { "index": 25, "kind": "property", "displayName": "Https Hostname Verification Enabled", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Whether SSL HostnameVerifier is enabled or not. Th [...]
- "password": { "index": 26, "kind": "property", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Password to be used for authentication against the MQTT broker" },
- "socketFactory": { "index": 27, "kind": "property", "displayName": "Socket Factory", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.SocketFactory", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SocketFactory to use. This allows an application to apply its own policies around the cr [...]
- "sslClientProps": { "index": 28, "kind": "property", "displayName": "Ssl Client Props", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SSL properties for the connection. Note that these properties are only valid if an imple [...]
- "sslHostnameVerifier": { "index": 29, "kind": "property", "displayName": "Ssl Hostname Verifier", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.ssl.HostnameVerifier", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the HostnameVerifier for the SSL connection. Note that it will be used a [...]
- "userName": { "index": 30, "kind": "property", "displayName": "User Name", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Username to be used for authentication against the MQTT broker" }
+ "manualAcksEnabled": { "index": 20, "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.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets whether to use manual acknowledgements for the client. By default, this is [...]
+ "lazyStartProducer": { "index": 21, "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 [...]
+ "autowiredEnabled": { "index": 22, "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 [...]
+ "client": { "index": 23, "kind": "property", "displayName": "Client", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.eclipse.paho.client.mqttv3.MqttClient", "deprecated": false, "autowired": false, "secret": false, "description": "To use a shared Paho client" },
+ "customWebSocketHeaders": { "index": 24, "kind": "property", "displayName": "Custom Web Socket Headers", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Custom WebSocket Headers for the WebSocket Connection." },
+ "executorServiceTimeout": { "index": 25, "kind": "property", "displayName": "Executor Service Timeout", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Set the time in seconds that the executor service should wait when terminating [...]
+ "httpsHostnameVerificationEnabled": { "index": 26, "kind": "property", "displayName": "Https Hostname Verification Enabled", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Whether SSL HostnameVerifier is enabled or not. Th [...]
+ "password": { "index": 27, "kind": "property", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Password to be used for authentication against the MQTT broker" },
+ "socketFactory": { "index": 28, "kind": "property", "displayName": "Socket Factory", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.SocketFactory", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SocketFactory to use. This allows an application to apply its own policies around the cr [...]
+ "sslClientProps": { "index": 29, "kind": "property", "displayName": "Ssl Client Props", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SSL properties for the connection. Note that these properties are only valid if an imple [...]
+ "sslHostnameVerifier": { "index": 30, "kind": "property", "displayName": "Ssl Hostname Verifier", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.ssl.HostnameVerifier", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the HostnameVerifier for the SSL connection. Note that it will be used a [...]
+ "userName": { "index": 31, "kind": "property", "displayName": "User Name", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Username to be used for authentication against the MQTT broker" }
},
"headers": {
"CamelMqttTopic": { "index": 0, "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the topic.", "constantName": "org.apache.camel.component.paho.PahoConstants#MQTT_TOPIC" },
@@ -83,18 +84,19 @@
"willQos": { "index": 16, "kind": "parameter", "displayName": "Will Qos", "group": "common", "label": "", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Last Will and Testament (LWT) for the connection. In the event that this client unexpectedly loses its connection to the server, [...]
"willRetained": { "index": 17, "kind": "parameter", "displayName": "Will Retained", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Last Will and Testament (LWT) for the connection. In the event that this client unexpectedl [...]
"willTopic": { "index": 18, "kind": "parameter", "displayName": "Will Topic", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Last Will and Testament (LWT) for the connection. In the event that this client unexpectedly loses its connectio [...]
- "bridgeErrorHandler": { "index": 19, "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": 20, "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": 21, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "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." },
- "lazyStartProducer": { "index": 22, "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 [...]
- "client": { "index": 23, "kind": "parameter", "displayName": "Client", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.eclipse.paho.client.mqttv3.MqttClient", "deprecated": false, "autowired": false, "secret": false, "description": "To use an existing mqtt client" },
- "customWebSocketHeaders": { "index": 24, "kind": "parameter", "displayName": "Custom Web Socket Headers", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Custom WebSocket Headers for the WebSocket Connection." },
- "executorServiceTimeout": { "index": 25, "kind": "parameter", "displayName": "Executor Service Timeout", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Set the time in seconds that the executor service should wait when terminatin [...]
- "httpsHostnameVerificationEnabled": { "index": 26, "kind": "parameter", "displayName": "Https Hostname Verification Enabled", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Whether SSL HostnameVerifier is enabled or not. T [...]
- "password": { "index": 27, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Password to be used for authentication against the MQTT broker" },
- "socketFactory": { "index": 28, "kind": "parameter", "displayName": "Socket Factory", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.SocketFactory", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SocketFactory to use. This allows an application to apply its own policies around the c [...]
- "sslClientProps": { "index": 29, "kind": "parameter", "displayName": "Ssl Client Props", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SSL properties for the connection. Note that these properties are only valid if an impl [...]
- "sslHostnameVerifier": { "index": 30, "kind": "parameter", "displayName": "Ssl Hostname Verifier", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.ssl.HostnameVerifier", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the HostnameVerifier for the SSL connection. Note that it will be used [...]
- "userName": { "index": 31, "kind": "parameter", "displayName": "User Name", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Username to be used for authentication against the MQTT broker" }
+ "manualAcksEnabled": { "index": 19, "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.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets whether to use manual acknowledgements for the client. By default, this is [...]
+ "bridgeErrorHandler": { "index": 20, "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": 21, "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": 22, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "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." },
+ "lazyStartProducer": { "index": 23, "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 [...]
+ "client": { "index": 24, "kind": "parameter", "displayName": "Client", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.eclipse.paho.client.mqttv3.MqttClient", "deprecated": false, "autowired": false, "secret": false, "description": "To use an existing mqtt client" },
+ "customWebSocketHeaders": { "index": 25, "kind": "parameter", "displayName": "Custom Web Socket Headers", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the Custom WebSocket Headers for the WebSocket Connection." },
+ "executorServiceTimeout": { "index": 26, "kind": "parameter", "displayName": "Executor Service Timeout", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Set the time in seconds that the executor service should wait when terminatin [...]
+ "httpsHostnameVerificationEnabled": { "index": 27, "kind": "parameter", "displayName": "Https Hostname Verification Enabled", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Whether SSL HostnameVerifier is enabled or not. T [...]
+ "password": { "index": 28, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Password to be used for authentication against the MQTT broker" },
+ "socketFactory": { "index": 29, "kind": "parameter", "displayName": "Socket Factory", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.SocketFactory", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SocketFactory to use. This allows an application to apply its own policies around the c [...]
+ "sslClientProps": { "index": 30, "kind": "parameter", "displayName": "Ssl Client Props", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "java.util.Properties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the SSL properties for the connection. Note that these properties are only valid if an impl [...]
+ "sslHostnameVerifier": { "index": 31, "kind": "parameter", "displayName": "Ssl Hostname Verifier", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "javax.net.ssl.HostnameVerifier", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Sets the HostnameVerifier for the SSL connection. Note that it will be used [...]
+ "userName": { "index": 32, "kind": "parameter", "displayName": "User Name", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.paho.PahoConfiguration", "configurationField": "configuration", "description": "Username to be used for authentication against the MQTT broker" }
}
}
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PahoComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PahoComponentBuilderFactory.java
index 93ffc12ab67..b70fdcf3dd7 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PahoComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PahoComponentBuilderFactory.java
@@ -462,6 +462,26 @@ public interface PahoComponentBuilderFactory {
}
+ /**
+ * Sets whether to use manual acknowledgements for the client. By
+ * default, this is false and message will be automatically
+ * acknowledged. If set to true, the acknowledgement is added in the
+ * exchange's completion callback.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param manualAcksEnabled the value to set
+ * @return the dsl builder
+ */
+ default PahoComponentBuilder manualAcksEnabled(boolean manualAcksEnabled) {
+ doSetProperty("manualAcksEnabled", manualAcksEnabled);
+ return this;
+ }
+
+
/**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
@@ -738,6 +758,7 @@ public interface PahoComponentBuilderFactory {
case "willRetained": getOrCreateConfiguration((PahoComponent) component).setWillRetained((boolean) value); return true;
case "willTopic": getOrCreateConfiguration((PahoComponent) component).setWillTopic((java.lang.String) value); return true;
case "bridgeErrorHandler": ((PahoComponent) component).setBridgeErrorHandler((boolean) value); return true;
+ case "manualAcksEnabled": getOrCreateConfiguration((PahoComponent) component).setManualAcksEnabled((boolean) value); return true;
case "lazyStartProducer": ((PahoComponent) component).setLazyStartProducer((boolean) value); return true;
case "autowiredEnabled": ((PahoComponent) component).setAutowiredEnabled((boolean) value); return true;
case "client": ((PahoComponent) component).setClient((org.eclipse.paho.client.mqttv3.MqttClient) value); return true;
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java
index c2132bf8d43..a69812ee770 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java
@@ -602,6 +602,42 @@ public interface PahoEndpointBuilderFactory {
doSetProperty("willTopic", willTopic);
return this;
}
+ /**
+ * Sets whether to use manual acknowledgements for the client. By
+ * default, this is false and message will be automatically
+ * acknowledged. If set to true, the acknowledgement is added in the
+ * exchange's completion callback.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param manualAcksEnabled the value to set
+ * @return the dsl builder
+ */
+ default PahoEndpointConsumerBuilder manualAcksEnabled(boolean manualAcksEnabled) {
+ doSetProperty("manualAcksEnabled", manualAcksEnabled);
+ return this;
+ }
+ /**
+ * Sets whether to use manual acknowledgements for the client. By
+ * default, this is false and message will be automatically
+ * acknowledged. If set to true, the acknowledgement is added in the
+ * exchange's completion callback.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param manualAcksEnabled the value to set
+ * @return the dsl builder
+ */
+ default PahoEndpointConsumerBuilder manualAcksEnabled(String manualAcksEnabled) {
+ doSetProperty("manualAcksEnabled", manualAcksEnabled);
+ return this;
+ }
/**
* Whether SSL HostnameVerifier is enabled or not. The default value is
* true.