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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 01b3f97cd17 Regen
01b3f97cd17 is described below
commit 01b3f97cd17ee51d4b3f324d2a2a893eae290f89
Author: Claus Ibsen <[email protected]>
AuthorDate: Thu Jul 3 19:43:44 2025 +0200
Regen
---
.../springboot/catalog/components/rocketmq.json | 72 ++++++++++++----------
.../src/main/docs/rocketmq.json | 34 ++++++++++
.../springboot/RocketMQComponentConfiguration.java | 62 +++++++++++++++++++
3 files changed, 137 insertions(+), 31 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/rocketmq.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/rocketmq.json
index 307926110fc..3676b64747e 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/rocketmq.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/rocketmq.json
@@ -24,21 +24,26 @@
"remote": true
},
"componentProperties": {
- "namesrvAddr": { "index": 0, "kind": "property", "displayName": "Namesrv
Addr", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "localhost:9876", "description": "Name
server address of RocketMQ cluster." },
- "sendTag": { "index": 1, "kind": "property", "displayName": "Send Tag",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Each message would be sent with this tag." },
- "bridgeErrorHandler": { "index": 2, "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 like [...]
- "consumerGroup": { "index": 3, "kind": "property", "displayName":
"Consumer Group", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Consumer group name." },
- "subscribeTags": { "index": 4, "kind": "property", "displayName":
"Subscribe Tags", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "*", "description":
"Subscribe tags of consumer. Multiple tags could be split by , such as
TagATagB" },
- "lazyStartProducer": { "index": 5, "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 fail [...]
- "producerGroup": { "index": 6, "kind": "property", "displayName":
"Producer Group", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Producer group name." },
- "replyToConsumerGroup": { "index": 7, "kind": "property", "displayName":
"Reply To Consumer Group", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description":
"Consumer group name used for receiving response." },
- "replyToTopic": { "index": 8, "kind": "property", "displayName": "Reply To
Topic", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Topic used for receiving response when
using in-out pattern." },
- "waitForSendResult": { "index": 9, "kind": "property", "displayName":
"Wait For Send Result", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether waiting for send result before routing to next endpoint." },
- "autowiredEnabled": { "index": 10, "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 [...]
- "requestTimeoutCheckerIntervalMillis": { "index": 11, "kind": "property",
"displayName": "Request Timeout Checker Interval Millis", "group": "advanced",
"label": "advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"description": "Check interval milliseconds of request timeout." },
- "requestTimeoutMillis": { "index": 12, "kind": "property", "displayName":
"Request Timeout Millis", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10000, "description": "Timeout
milliseconds of receiving response when using in-out pattern." },
- "accessKey": { "index": 13, "kind": "property", "displayName": "Access
Key", "group": "secret", "label": "secret", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Access key for RocketMQ ACL." },
- "secretKey": { "index": 14, "kind": "property", "displayName": "Secret
Key", "group": "secret", "label": "secret", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Secret key for RocketMQ ACL." }
+ "accessChannel": { "index": 0, "kind": "property", "displayName": "Access
Channel", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "LOCAL", "description": "Access channel
of RocketMQ cluster. LOCAL or CLOUD, LOCAL by default" },
+ "enableTrace": { "index": 1, "kind": "property", "displayName": "Enable
Trace", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether to enable
trace." },
+ "namespace": { "index": 2, "kind": "property", "displayName": "Namespace",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Namespace of RocketMQ cluster. You need to
specify this if you are using serverless version of RocketMQ." },
+ "namesrvAddr": { "index": 3, "kind": "property", "displayName": "Namesrv
Addr", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "localhost:9876", "description": "Name
server address of RocketMQ cluster." },
+ "sendTag": { "index": 4, "kind": "property", "displayName": "Send Tag",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Each message would be sent with this tag." },
+ "bridgeErrorHandler": { "index": 5, "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 like [...]
+ "consumerGroup": { "index": 6, "kind": "property", "displayName":
"Consumer Group", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Consumer group name." },
+ "messageSelectorType": { "index": 7, "kind": "property", "displayName":
"Message Selector Type", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "tag", "description":
"Message Selector Type, TAG or SQL TAG by default" },
+ "subscribeSql": { "index": 8, "kind": "property", "displayName":
"Subscribe Sql", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1 = 1", "description":
"Subscribe SQL of consumer. See
https:\/\/rocketmq.apache.org\/docs\/featureBehavior\/07messagefilter\/#attribute-based-sql-filtering
for more details." },
+ "subscribeTags": { "index": 9, "kind": "property", "displayName":
"Subscribe Tags", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "*", "description":
"Subscribe tags of consumer. Multiple tags could be split by , such as
TagATagB" },
+ "lazyStartProducer": { "index": 10, "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 [...]
+ "producerGroup": { "index": 11, "kind": "property", "displayName":
"Producer Group", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Producer group name." },
+ "replyToConsumerGroup": { "index": 12, "kind": "property", "displayName":
"Reply To Consumer Group", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description":
"Consumer group name used for receiving response." },
+ "replyToTopic": { "index": 13, "kind": "property", "displayName": "Reply
To Topic", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Topic used for receiving response when
using in-out pattern." },
+ "waitForSendResult": { "index": 14, "kind": "property", "displayName":
"Wait For Send Result", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether waiting for send result before routing to next endpoint." },
+ "autowiredEnabled": { "index": 15, "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 [...]
+ "requestTimeoutCheckerIntervalMillis": { "index": 16, "kind": "property",
"displayName": "Request Timeout Checker Interval Millis", "group": "advanced",
"label": "advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"description": "Check interval milliseconds of request timeout." },
+ "requestTimeoutMillis": { "index": 17, "kind": "property", "displayName":
"Request Timeout Millis", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10000, "description": "Timeout
milliseconds of receiving response when using in-out pattern." },
+ "accessKey": { "index": 18, "kind": "property", "displayName": "Access
Key", "group": "secret", "label": "secret", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Access key for RocketMQ ACL." },
+ "secretKey": { "index": 19, "kind": "property", "displayName": "Secret
Key", "group": "secret", "label": "secret", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Secret key for RocketMQ ACL." }
},
"headers": {
"CamelRockerMQTopic": { "index": 0, "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Topic of message", "constantName":
"org.apache.camel.component.rocketmq.RocketMQConstants#TOPIC" },
@@ -64,21 +69,26 @@
},
"properties": {
"topicName": { "index": 0, "kind": "path", "displayName": "Topic Name",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Topic name of this endpoint." },
- "namesrvAddr": { "index": 1, "kind": "parameter", "displayName": "Namesrv
Addr", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "localhost:9876", "description": "Name
server address of RocketMQ cluster." },
- "consumerGroup": { "index": 2, "kind": "parameter", "displayName":
"Consumer Group", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Consumer group name." },
- "subscribeTags": { "index": 3, "kind": "parameter", "displayName":
"Subscribe Tags", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "*", "description":
"Subscribe tags of consumer. Multiple tags could be split by , such as
TagATagB" },
- "bridgeErrorHandler": { "index": 4, "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": 5, "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 def [...]
- "exchangePattern": { "index": 6, "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." },
- "producerGroup": { "index": 7, "kind": "parameter", "displayName":
"Producer Group", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Producer group name." },
- "replyToConsumerGroup": { "index": 8, "kind": "parameter", "displayName":
"Reply To Consumer Group", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description":
"Consumer group name used for receiving response." },
- "replyToTopic": { "index": 9, "kind": "parameter", "displayName": "Reply
To Topic", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Topic used for receiving response when
using in-out pattern." },
- "sendTag": { "index": 10, "kind": "parameter", "displayName": "Send Tag",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Each message would be sent with this tag." },
- "waitForSendResult": { "index": 11, "kind": "parameter", "displayName":
"Wait For Send Result", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether waiting for send result before routing to next endpoint." },
- "lazyStartProducer": { "index": 12, "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 [...]
- "requestTimeoutCheckerIntervalMillis": { "index": 13, "kind": "parameter",
"displayName": "Request Timeout Checker Interval Millis", "group": "advanced",
"label": "advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"description": "Check interval milliseconds of request timeout." },
- "requestTimeoutMillis": { "index": 14, "kind": "parameter", "displayName":
"Request Timeout Millis", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10000, "description": "Timeout
milliseconds of receiving response when using in-out pattern." },
- "accessKey": { "index": 15, "kind": "parameter", "displayName": "Access
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Access key for RocketMQ ACL." },
- "secretKey": { "index": 16, "kind": "parameter", "displayName": "Secret
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Secret key for RocketMQ ACL." }
+ "accessChannel": { "index": 1, "kind": "parameter", "displayName": "Access
Channel", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "LOCAL", "description": "Access channel
of RocketMQ cluster. LOCAL or CLOUD, LOCAL by default" },
+ "enableTrace": { "index": 2, "kind": "parameter", "displayName": "Enable
Trace", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether to enable
trace." },
+ "namespace": { "index": 3, "kind": "parameter", "displayName":
"Namespace", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Namespace of RocketMQ cluster. You need
to specify this if you are using serverless version of RocketMQ." },
+ "namesrvAddr": { "index": 4, "kind": "parameter", "displayName": "Namesrv
Addr", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "localhost:9876", "description": "Name
server address of RocketMQ cluster." },
+ "consumerGroup": { "index": 5, "kind": "parameter", "displayName":
"Consumer Group", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Consumer group name." },
+ "messageSelectorType": { "index": 6, "kind": "parameter", "displayName":
"Message Selector Type", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "tag", "description":
"Message Selector Type, TAG or SQL TAG by default" },
+ "subscribeSql": { "index": 7, "kind": "parameter", "displayName":
"Subscribe Sql", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1 = 1", "description":
"Subscribe SQL of consumer. See
https:\/\/rocketmq.apache.org\/docs\/featureBehavior\/07messagefilter\/#attribute-based-sql-filtering
for more details." },
+ "subscribeTags": { "index": 8, "kind": "parameter", "displayName":
"Subscribe Tags", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "*", "description":
"Subscribe tags of consumer. Multiple tags could be split by , such as
TagATagB" },
+ "bridgeErrorHandler": { "index": 9, "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": 10, "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": 11, "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." },
+ "producerGroup": { "index": 12, "kind": "parameter", "displayName":
"Producer Group", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Producer group name." },
+ "replyToConsumerGroup": { "index": 13, "kind": "parameter", "displayName":
"Reply To Consumer Group", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description":
"Consumer group name used for receiving response." },
+ "replyToTopic": { "index": 14, "kind": "parameter", "displayName": "Reply
To Topic", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Topic used for receiving response when
using in-out pattern." },
+ "sendTag": { "index": 15, "kind": "parameter", "displayName": "Send Tag",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Each message would be sent with this tag." },
+ "waitForSendResult": { "index": 16, "kind": "parameter", "displayName":
"Wait For Send Result", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether waiting for send result before routing to next endpoint." },
+ "lazyStartProducer": { "index": 17, "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 [...]
+ "requestTimeoutCheckerIntervalMillis": { "index": 18, "kind": "parameter",
"displayName": "Request Timeout Checker Interval Millis", "group": "advanced",
"label": "advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"description": "Check interval milliseconds of request timeout." },
+ "requestTimeoutMillis": { "index": 19, "kind": "parameter", "displayName":
"Request Timeout Millis", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10000, "description": "Timeout
milliseconds of receiving response when using in-out pattern." },
+ "accessKey": { "index": 20, "kind": "parameter", "displayName": "Access
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Access key for RocketMQ ACL." },
+ "secretKey": { "index": 21, "kind": "parameter", "displayName": "Secret
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "description": "Secret key for RocketMQ ACL." }
}
}
diff --git
a/components-starter/camel-rocketmq-starter/src/main/docs/rocketmq.json
b/components-starter/camel-rocketmq-starter/src/main/docs/rocketmq.json
index a2ca569a0d9..baf0363a643 100644
--- a/components-starter/camel-rocketmq-starter/src/main/docs/rocketmq.json
+++ b/components-starter/camel-rocketmq-starter/src/main/docs/rocketmq.json
@@ -13,6 +13,13 @@
}
],
"properties": [
+ {
+ "name": "camel.component.rocketmq.access-channel",
+ "type": "java.lang.String",
+ "description": "Access channel of RocketMQ cluster. LOCAL or CLOUD,
LOCAL by default",
+ "sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration",
+ "defaultValue": "LOCAL"
+ },
{
"name": "camel.component.rocketmq.access-key",
"type": "java.lang.String",
@@ -44,6 +51,13 @@
"type": "java.lang.Boolean",
"sourceType":
"org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon$CustomizerProperties"
},
+ {
+ "name": "camel.component.rocketmq.enable-trace",
+ "type": "java.lang.Boolean",
+ "description": "Whether to enable trace.",
+ "sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration",
+ "defaultValue": false
+ },
{
"name": "camel.component.rocketmq.enabled",
"type": "java.lang.Boolean",
@@ -57,6 +71,19 @@
"sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.rocketmq.message-selector-type",
+ "type": "java.lang.String",
+ "description": "Message Selector Type, TAG or SQL TAG by default",
+ "sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration",
+ "defaultValue": "tag"
+ },
+ {
+ "name": "camel.component.rocketmq.namespace",
+ "type": "java.lang.String",
+ "description": "Namespace of RocketMQ cluster. You need to specify this
if you are using serverless version of RocketMQ.",
+ "sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration"
+ },
{
"name": "camel.component.rocketmq.namesrv-addr",
"type": "java.lang.String",
@@ -108,6 +135,13 @@
"description": "Each message would be sent with this tag.",
"sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration"
},
+ {
+ "name": "camel.component.rocketmq.subscribe-sql",
+ "type": "java.lang.String",
+ "description": "Subscribe SQL of consumer. See
https:\/\/rocketmq.apache.org\/docs\/featureBehavior\/07messagefilter\/#attribute-based-sql-filtering
for more details.",
+ "sourceType":
"org.apache.camel.component.rocketmq.springboot.RocketMQComponentConfiguration",
+ "defaultValue": "1 = 1"
+ },
{
"name": "camel.component.rocketmq.subscribe-tags",
"type": "java.lang.String",
diff --git
a/components-starter/camel-rocketmq-starter/src/main/java/org/apache/camel/component/rocketmq/springboot/RocketMQComponentConfiguration.java
b/components-starter/camel-rocketmq-starter/src/main/java/org/apache/camel/component/rocketmq/springboot/RocketMQComponentConfiguration.java
index a6a7544e56f..da05e9f2db9 100644
---
a/components-starter/camel-rocketmq-starter/src/main/java/org/apache/camel/component/rocketmq/springboot/RocketMQComponentConfiguration.java
+++
b/components-starter/camel-rocketmq-starter/src/main/java/org/apache/camel/component/rocketmq/springboot/RocketMQComponentConfiguration.java
@@ -34,6 +34,19 @@ public class RocketMQComponentConfiguration
* enabled by default.
*/
private Boolean enabled;
+ /**
+ * Access channel of RocketMQ cluster. LOCAL or CLOUD, LOCAL by default
+ */
+ private String accessChannel = "LOCAL";
+ /**
+ * Whether to enable trace.
+ */
+ private Boolean enableTrace = false;
+ /**
+ * Namespace of RocketMQ cluster. You need to specify this if you are using
+ * serverless version of RocketMQ.
+ */
+ private String namespace;
/**
* Name server address of RocketMQ cluster.
*/
@@ -60,6 +73,15 @@ public class RocketMQComponentConfiguration
* Consumer group name.
*/
private String consumerGroup;
+ /**
+ * Message Selector Type, TAG or SQL TAG by default
+ */
+ private String messageSelectorType = "tag";
+ /**
+ * Subscribe SQL of consumer. See
+ *
https://rocketmq.apache.org/docs/featureBehavior/07messagefilter/#attribute-based-sql-filtering
for more details.
+ */
+ private String subscribeSql = "1 = 1";
/**
* Subscribe tags of consumer. Multiple tags could be split by , such as
* TagATagB
@@ -118,6 +140,30 @@ public class RocketMQComponentConfiguration
*/
private String secretKey;
+ public String getAccessChannel() {
+ return accessChannel;
+ }
+
+ public void setAccessChannel(String accessChannel) {
+ this.accessChannel = accessChannel;
+ }
+
+ public Boolean getEnableTrace() {
+ return enableTrace;
+ }
+
+ public void setEnableTrace(Boolean enableTrace) {
+ this.enableTrace = enableTrace;
+ }
+
+ public String getNamespace() {
+ return namespace;
+ }
+
+ public void setNamespace(String namespace) {
+ this.namespace = namespace;
+ }
+
public String getNamesrvAddr() {
return namesrvAddr;
}
@@ -150,6 +196,22 @@ public class RocketMQComponentConfiguration
this.consumerGroup = consumerGroup;
}
+ public String getMessageSelectorType() {
+ return messageSelectorType;
+ }
+
+ public void setMessageSelectorType(String messageSelectorType) {
+ this.messageSelectorType = messageSelectorType;
+ }
+
+ public String getSubscribeSql() {
+ return subscribeSql;
+ }
+
+ public void setSubscribeSql(String subscribeSql) {
+ this.subscribeSql = subscribeSql;
+ }
+
public String getSubscribeTags() {
return subscribeTags;
}
