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 2022/12/07 09:35:36 UTC
[camel] branch main updated: CAMEL-14831: Regen
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 3921ba27f0b CAMEL-14831: Regen
3921ba27f0b is described below
commit 3921ba27f0b82bfd403678a250ac567c3c0f8389
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Dec 7 10:35:20 2022 +0100
CAMEL-14831: Regen
---
bom/camel-bom/pom.xml | 5 +
camel-dependencies/pom.xml | 1 +
.../org/apache/camel/catalog/components.properties | 1 +
.../apache/camel/catalog/components/rocketmq.json | 82 ++
.../org/apache/camel/main/components.properties | 1 +
.../modules/ROOT/examples/json/rocketmq.json | 1 +
docs/components/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/rocketmq-component.adoc | 1 +
.../component/ComponentsBuilderFactory.java | 13 +
.../dsl/RocketmqComponentBuilderFactory.java | 339 +++++++
.../src/generated/resources/metadata.json | 22 +
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/StaticEndpointBuilders.java | 43 +
.../dsl/RocketMQEndpointBuilderFactory.java | 1055 ++++++++++++++++++++
.../camel-component-known-dependencies.properties | 1 +
16 files changed, 1568 insertions(+)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index a31145c9390..b6858c72ff7 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -1706,6 +1706,11 @@
<artifactId>camel-robotframework</artifactId>
<version>${project.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-rocketmq</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-route-parser</artifactId>
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index 05de672eccb..2791900f8e2 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -481,6 +481,7 @@
<resteasy-version>4.5.6.Final</resteasy-version>
<roaster-version>2.26.0.Final</roaster-version>
<robotframework-version>4.1.2</robotframework-version>
+ <rocketmq-version>4.9.4</rocketmq-version>
<rome-version>1.18.0</rome-version>
<rxjava2-version>2.2.21</rxjava2-version>
<saxon-version>11.4</saxon-version>
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index 13c2ba81815..fe1b8342514 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -270,6 +270,7 @@ rest-openapi
rest-swagger
resteasy
robotframework
+rocketmq
rss
saga
salesforce
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/rocketmq.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/rocketmq.json
new file mode 100644
index 00000000000..ed2629825c3
--- /dev/null
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/rocketmq.json
@@ -0,0 +1,82 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "rocketmq",
+ "title": "RocketMQ",
+ "description": "Send and receive messages from RocketMQ cluster.",
+ "deprecated": false,
+ "firstVersion": "3.20.0",
+ "label": "messaging",
+ "javaType": "org.apache.camel.component.rocketmq.RocketMQComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-rocketmq",
+ "version": "3.20.0-SNAPSHOT",
+ "scheme": "rocketmq",
+ "extendsScheme": "",
+ "syntax": "rocketmq:topicName",
+ "async": true,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
+ "componentProperties": {
+ "namesrvAddr": { "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": { "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": { "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 occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a me [...]
+ "consumerGroup": { "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": { "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": { "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 during star [...]
+ "producerGroup": { "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": { "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": { "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": { "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": { "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 type, which t [...]
+ "requestTimeoutCheckerIntervalMillis": { "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": { "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": { "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": { "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": { "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" },
+ "CamelRockerMQTag": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Tag of message", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#TAG" },
+ "CamelRockerMQKey": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Key of message", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#KEY" },
+ "CamelRockerMQOverrideTopicName": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If this header is set, the message will be routed to the topic specified by this header instead of the origin topic in endpoint.", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#OVERRIDE_TOPIC_NAME" },
+ "CamelRockerMQOverrideTag": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If this header is set, the message's tag will be set to value specified by this header instead of the sendTag defined in endpoint.", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#OVERRIDE_TAG" },
+ "CamelRockerMQOverrideMessageKey": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Set keys for the message. When using in-out pattern, the value will be prepended to the generated keys", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#OVERRIDE_MESSAGE_KEY" },
+ "CamelRockerMQBrokerName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Broker name", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#BROKER_NAME" },
+ "CamelRockerMQQueueId": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Queue ID", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#QUEUE_ID" },
+ "CamelRockerMQStoreSize": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Store size", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#STORE_SIZE" },
+ "CamelRockerMQQueueOffset": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Queue offset", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#QUEUE_OFFSET" },
+ "CamelRockerMQSysFlag": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Sys flag", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#SYS_FLAG" },
+ "CamelRockerMQBornTimestamp": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Born timestamp", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#BORN_TIMESTAMP" },
+ "CamelRockerMQBornHost": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "java.net.SocketAddress", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Born host", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#BORN_HOST" },
+ "CamelRockerMQStoreTimestamp": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Store timestamp", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#STORE_TIMESTAMP" },
+ "CamelRockerMQStoreHost": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "java.net.SocketAddress", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Store host", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#STORE_HOST" },
+ "CamelRockerMQMsgId": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Msg ID", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#MSG_ID" },
+ "CamelRockerMQCommitLogOffset": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Commit log offset", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#COMMIT_LOG_OFFSET" },
+ "CamelRockerMQBodyCrc": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Body CRC", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#BODY_CRC" },
+ "CamelRockerMQReconsumeTimes": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Reconsume times", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#RECONSUME_TIMES" },
+ "CamelRockerMQPreparedTransactionOffset": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Prepard transaction offset", "constantName": "org.apache.camel.component.rocketmq.RocketMQConstants#PREPARED_TRANSACTION_OFFSET" }
+ },
+ "properties": {
+ "topicName": { "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": { "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": { "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": { "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": { "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 occurred while the consumer is trying to pickup incoming messages, or the likes, will now [...]
+ "exceptionHandler": { "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 default the con [...]
+ "exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
+ "producerGroup": { "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": { "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": { "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": { "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": { "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": { "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 producer may other [...]
+ "requestTimeoutCheckerIntervalMillis": { "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": { "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": { "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": { "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/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
index 13c2ba81815..fe1b8342514 100644
--- a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
+++ b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
@@ -270,6 +270,7 @@ rest-openapi
rest-swagger
resteasy
robotframework
+rocketmq
rss
saga
salesforce
diff --git a/docs/components/modules/ROOT/examples/json/rocketmq.json b/docs/components/modules/ROOT/examples/json/rocketmq.json
new file mode 120000
index 00000000000..b101229de7d
--- /dev/null
+++ b/docs/components/modules/ROOT/examples/json/rocketmq.json
@@ -0,0 +1 @@
+../../../../../../components/camel-rocketmq/src/generated/resources/org/apache/camel/component/rocketmq/rocketmq.json
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc b/docs/components/modules/ROOT/nav.adoc
index 158501e9933..878b1b33e40 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -278,6 +278,7 @@
** xref:rest-swagger-component.adoc[REST Swagger]
** xref:resteasy-component.adoc[Resteasy]
** xref:robotframework-component.adoc[Robot Framework]
+** xref:rocketmq-component.adoc[RocketMQ]
** xref:rss-component.adoc[RSS]
** xref:saga-component.adoc[Saga]
** xref:salesforce-component.adoc[Salesforce]
diff --git a/docs/components/modules/ROOT/pages/rocketmq-component.adoc b/docs/components/modules/ROOT/pages/rocketmq-component.adoc
new file mode 120000
index 00000000000..4c1aad0c9c8
--- /dev/null
+++ b/docs/components/modules/ROOT/pages/rocketmq-component.adoc
@@ -0,0 +1 @@
+../../../../../components/camel-rocketmq/src/main/docs/rocketmq-component.adoc
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index 3d5d9892fdc..014bba87ea0 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -3667,6 +3667,19 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.RobotframeworkComponentBuilderFactory.RobotframeworkComponentBuilder robotframework() {
return org.apache.camel.builder.component.dsl.RobotframeworkComponentBuilderFactory.robotframework();
}
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * @return the dsl builder
+ */
+ static org.apache.camel.builder.component.dsl.RocketmqComponentBuilderFactory.RocketmqComponentBuilder rocketmq() {
+ return org.apache.camel.builder.component.dsl.RocketmqComponentBuilderFactory.rocketmq();
+ }
/**
* RSS (camel-rss)
* Poll RSS feeds.
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/RocketmqComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/RocketmqComponentBuilderFactory.java
new file mode 100644
index 00000000000..4ed4bbca871
--- /dev/null
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/RocketmqComponentBuilderFactory.java
@@ -0,0 +1,339 @@
+/*
+ * 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.builder.component.dsl;
+
+import javax.annotation.Generated;
+import org.apache.camel.Component;
+import org.apache.camel.builder.component.AbstractComponentBuilder;
+import org.apache.camel.builder.component.ComponentBuilder;
+import org.apache.camel.component.rocketmq.RocketMQComponent;
+
+/**
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
+public interface RocketmqComponentBuilderFactory {
+
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * @return the dsl builder
+ */
+ static RocketmqComponentBuilder rocketmq() {
+ return new RocketmqComponentBuilderImpl();
+ }
+
+ /**
+ * Builder for the RocketMQ component.
+ */
+ interface RocketmqComponentBuilder
+ extends
+ ComponentBuilder<RocketMQComponent> {
+ /**
+ * Name server address of RocketMQ cluster.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: localhost:9876
+ * Group: common
+ *
+ * @param namesrvAddr the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder namesrvAddr(
+ java.lang.String namesrvAddr) {
+ doSetProperty("namesrvAddr", namesrvAddr);
+ return this;
+ }
+ /**
+ * Each message would be sent with this tag.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param sendTag the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder sendTag(java.lang.String sendTag) {
+ doSetProperty("sendTag", sendTag);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. 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.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * Consumer group name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param consumerGroup the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder consumerGroup(
+ java.lang.String consumerGroup) {
+ doSetProperty("consumerGroup", consumerGroup);
+ return this;
+ }
+ /**
+ * Subscribe tags of consumer. Multiple tags could be split by , such as
+ * TagATagB.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: *
+ * Group: consumer
+ *
+ * @param subscribeTags the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder subscribeTags(
+ java.lang.String subscribeTags) {
+ doSetProperty("subscribeTags", subscribeTags);
+ 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
+ * 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.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param lazyStartProducer the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder lazyStartProducer(
+ boolean lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ /**
+ * Producer group name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param producerGroup the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder producerGroup(
+ java.lang.String producerGroup) {
+ doSetProperty("producerGroup", producerGroup);
+ return this;
+ }
+ /**
+ * Consumer group name used for receiving response.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param replyToConsumerGroup the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder replyToConsumerGroup(
+ java.lang.String replyToConsumerGroup) {
+ doSetProperty("replyToConsumerGroup", replyToConsumerGroup);
+ return this;
+ }
+ /**
+ * Topic used for receiving response when using in-out pattern.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param replyToTopic the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder replyToTopic(
+ java.lang.String replyToTopic) {
+ doSetProperty("replyToTopic", replyToTopic);
+ return this;
+ }
+ /**
+ * Whether waiting for send result before routing to next endpoint.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param waitForSendResult the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder waitForSendResult(
+ boolean waitForSendResult) {
+ doSetProperty("waitForSendResult", waitForSendResult);
+ return this;
+ }
+ /**
+ * 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.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: advanced
+ *
+ * @param autowiredEnabled the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder autowiredEnabled(
+ boolean autowiredEnabled) {
+ doSetProperty("autowiredEnabled", autowiredEnabled);
+ return this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder requestTimeoutCheckerIntervalMillis(
+ long requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder requestTimeoutMillis(
+ long requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ /**
+ * Access key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: secret
+ *
+ * @param accessKey the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder accessKey(java.lang.String accessKey) {
+ doSetProperty("accessKey", accessKey);
+ return this;
+ }
+ /**
+ * Secret key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: secret
+ *
+ * @param secretKey the value to set
+ * @return the dsl builder
+ */
+ default RocketmqComponentBuilder secretKey(java.lang.String secretKey) {
+ doSetProperty("secretKey", secretKey);
+ return this;
+ }
+ }
+
+ class RocketmqComponentBuilderImpl
+ extends
+ AbstractComponentBuilder<RocketMQComponent>
+ implements
+ RocketmqComponentBuilder {
+ @Override
+ protected RocketMQComponent buildConcreteComponent() {
+ return new RocketMQComponent();
+ }
+ @Override
+ protected boolean setPropertyOnComponent(
+ Component component,
+ String name,
+ Object value) {
+ switch (name) {
+ case "namesrvAddr": ((RocketMQComponent) component).setNamesrvAddr((java.lang.String) value); return true;
+ case "sendTag": ((RocketMQComponent) component).setSendTag((java.lang.String) value); return true;
+ case "bridgeErrorHandler": ((RocketMQComponent) component).setBridgeErrorHandler((boolean) value); return true;
+ case "consumerGroup": ((RocketMQComponent) component).setConsumerGroup((java.lang.String) value); return true;
+ case "subscribeTags": ((RocketMQComponent) component).setSubscribeTags((java.lang.String) value); return true;
+ case "lazyStartProducer": ((RocketMQComponent) component).setLazyStartProducer((boolean) value); return true;
+ case "producerGroup": ((RocketMQComponent) component).setProducerGroup((java.lang.String) value); return true;
+ case "replyToConsumerGroup": ((RocketMQComponent) component).setReplyToConsumerGroup((java.lang.String) value); return true;
+ case "replyToTopic": ((RocketMQComponent) component).setReplyToTopic((java.lang.String) value); return true;
+ case "waitForSendResult": ((RocketMQComponent) component).setWaitForSendResult((boolean) value); return true;
+ case "autowiredEnabled": ((RocketMQComponent) component).setAutowiredEnabled((boolean) value); return true;
+ case "requestTimeoutCheckerIntervalMillis": ((RocketMQComponent) component).setRequestTimeoutCheckerIntervalMillis((long) value); return true;
+ case "requestTimeoutMillis": ((RocketMQComponent) component).setRequestTimeoutMillis((long) value); return true;
+ case "accessKey": ((RocketMQComponent) component).setAccessKey((java.lang.String) value); return true;
+ case "secretKey": ((RocketMQComponent) component).setSecretKey((java.lang.String) value); return true;
+ default: return false;
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index 19516448602..a5c1b183cfc 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -6027,6 +6027,28 @@
"producerOnly": false,
"lenientProperties": false
},
+ "RocketmqComponentBuilderFactory": {
+ "kind": "component",
+ "name": "rocketmq",
+ "title": "RocketMQ",
+ "description": "Send and receive messages from RocketMQ cluster.",
+ "deprecated": false,
+ "firstVersion": "3.20.0",
+ "label": "messaging",
+ "javaType": "org.apache.camel.component.rocketmq.RocketMQComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-rocketmq",
+ "version": "3.20.0-SNAPSHOT",
+ "scheme": "rocketmq",
+ "extendsScheme": "",
+ "syntax": "rocketmq:topicName",
+ "async": true,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
"RssComponentBuilderFactory": {
"kind": "component",
"name": "rss",
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index 8cb675d87fb..6084e60cf7e 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -286,6 +286,7 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.RestSwaggerEndpointBuilderFactory.RestSwaggerBuilders,
org.apache.camel.builder.endpoint.dsl.ResteasyEndpointBuilderFactory.ResteasyBuilders,
org.apache.camel.builder.endpoint.dsl.RobotFrameworkEndpointBuilderFactory.RobotFrameworkBuilders,
+ org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.RocketMQBuilders,
org.apache.camel.builder.endpoint.dsl.RssEndpointBuilderFactory.RssBuilders,
org.apache.camel.builder.endpoint.dsl.STS2EndpointBuilderFactory.STS2Builders,
org.apache.camel.builder.endpoint.dsl.SagaEndpointBuilderFactory.SagaBuilders,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index ba1748eafa1..5d9763bc4c9 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -283,6 +283,7 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.RestSwaggerEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ResteasyEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.RobotFrameworkEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.RssEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.STS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.SagaEndpointBuilderFactory,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index c0ff958241f..79074855a63 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -12733,6 +12733,49 @@ public class StaticEndpointBuilders {
String path) {
return org.apache.camel.builder.endpoint.dsl.RobotFrameworkEndpointBuilderFactory.endpointBuilder(componentName, path);
}
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * Syntax: <code>rocketmq:topicName</code>
+ *
+ * Path parameter: topicName (required)
+ * Topic name of this endpoint.
+ *
+ * @param path topicName
+ * @return the dsl builder
+ */
+ public static org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder rocketmq(
+ String path) {
+ return org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.endpointBuilder("rocketmq", path);
+ }
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * Syntax: <code>rocketmq:topicName</code>
+ *
+ * Path parameter: topicName (required)
+ * Topic name of this endpoint.
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path topicName
+ * @return the dsl builder
+ */
+ public static org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder rocketmq(
+ String componentName,
+ String path) {
+ return org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
/**
* RSS (camel-rss)
* Poll RSS feeds.
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RocketMQEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RocketMQEndpointBuilderFactory.java
new file mode 100644
index 00000000000..dce95a85e94
--- /dev/null
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/RocketMQEndpointBuilderFactory.java
@@ -0,0 +1,1055 @@
+/*
+ * 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.builder.endpoint.dsl;
+
+import java.util.*;
+import java.util.concurrent.*;
+import java.util.function.*;
+import java.util.stream.*;
+import javax.annotation.Generated;
+import org.apache.camel.builder.EndpointConsumerBuilder;
+import org.apache.camel.builder.EndpointProducerBuilder;
+import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
+
+/**
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
+public interface RocketMQEndpointBuilderFactory {
+
+
+ /**
+ * Builder for endpoint consumers for the RocketMQ component.
+ */
+ public interface RocketMQEndpointConsumerBuilder
+ extends
+ EndpointConsumerBuilder {
+ default AdvancedRocketMQEndpointConsumerBuilder advanced() {
+ return (AdvancedRocketMQEndpointConsumerBuilder) this;
+ }
+ /**
+ * Name server address of RocketMQ cluster.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: localhost:9876
+ * Group: common
+ *
+ * @param namesrvAddr the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointConsumerBuilder namesrvAddr(String namesrvAddr) {
+ doSetProperty("namesrvAddr", namesrvAddr);
+ return this;
+ }
+ /**
+ * Consumer group name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param consumerGroup the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointConsumerBuilder consumerGroup(
+ String consumerGroup) {
+ doSetProperty("consumerGroup", consumerGroup);
+ return this;
+ }
+ /**
+ * Subscribe tags of consumer. Multiple tags could be split by , such as
+ * TagATagB.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: *
+ * Group: consumer
+ *
+ * @param subscribeTags the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointConsumerBuilder subscribeTags(
+ String subscribeTags) {
+ doSetProperty("subscribeTags", subscribeTags);
+ return this;
+ }
+ /**
+ * Access key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param accessKey the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointConsumerBuilder accessKey(String accessKey) {
+ doSetProperty("accessKey", accessKey);
+ return this;
+ }
+ /**
+ * Secret key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param secretKey the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointConsumerBuilder secretKey(String secretKey) {
+ doSetProperty("secretKey", secretKey);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint consumers for the RocketMQ component.
+ */
+ public interface AdvancedRocketMQEndpointConsumerBuilder
+ extends
+ EndpointConsumerBuilder {
+ default RocketMQEndpointConsumerBuilder basic() {
+ return (RocketMQEndpointConsumerBuilder) this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. 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.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer (advanced)
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. 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.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: consumer (advanced)
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder bridgeErrorHandler(
+ String bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * To let the consumer use a custom ExceptionHandler. Notice if the
+ * option bridgeErrorHandler is enabled then this option is not in use.
+ * By default the consumer will deal with exceptions, that will be
+ * logged at WARN or ERROR level and ignored.
+ *
+ * The option is a:
+ * <code>org.apache.camel.spi.ExceptionHandler</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exceptionHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder exceptionHandler(
+ org.apache.camel.spi.ExceptionHandler exceptionHandler) {
+ doSetProperty("exceptionHandler", exceptionHandler);
+ return this;
+ }
+ /**
+ * To let the consumer use a custom ExceptionHandler. Notice if the
+ * option bridgeErrorHandler is enabled then this option is not in use.
+ * By default the consumer will deal with exceptions, that will be
+ * logged at WARN or ERROR level and ignored.
+ *
+ * The option will be converted to a
+ * <code>org.apache.camel.spi.ExceptionHandler</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exceptionHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder exceptionHandler(
+ String exceptionHandler) {
+ doSetProperty("exceptionHandler", exceptionHandler);
+ return this;
+ }
+ /**
+ * Sets the exchange pattern when the consumer creates an exchange.
+ *
+ * The option is a:
+ * <code>org.apache.camel.ExchangePattern</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exchangePattern the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder exchangePattern(
+ org.apache.camel.ExchangePattern exchangePattern) {
+ doSetProperty("exchangePattern", exchangePattern);
+ return this;
+ }
+ /**
+ * Sets the exchange pattern when the consumer creates an exchange.
+ *
+ * The option will be converted to a
+ * <code>org.apache.camel.ExchangePattern</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exchangePattern the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder exchangePattern(
+ String exchangePattern) {
+ doSetProperty("exchangePattern", exchangePattern);
+ return this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder requestTimeoutCheckerIntervalMillis(
+ long requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder requestTimeoutCheckerIntervalMillis(
+ String requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder requestTimeoutMillis(
+ long requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointConsumerBuilder requestTimeoutMillis(
+ String requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ }
+
+ /**
+ * Builder for endpoint producers for the RocketMQ component.
+ */
+ public interface RocketMQEndpointProducerBuilder
+ extends
+ EndpointProducerBuilder {
+ default AdvancedRocketMQEndpointProducerBuilder advanced() {
+ return (AdvancedRocketMQEndpointProducerBuilder) this;
+ }
+ /**
+ * Name server address of RocketMQ cluster.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: localhost:9876
+ * Group: common
+ *
+ * @param namesrvAddr the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder namesrvAddr(String namesrvAddr) {
+ doSetProperty("namesrvAddr", namesrvAddr);
+ return this;
+ }
+ /**
+ * Producer group name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param producerGroup the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder producerGroup(
+ String producerGroup) {
+ doSetProperty("producerGroup", producerGroup);
+ return this;
+ }
+ /**
+ * Consumer group name used for receiving response.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param replyToConsumerGroup the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder replyToConsumerGroup(
+ String replyToConsumerGroup) {
+ doSetProperty("replyToConsumerGroup", replyToConsumerGroup);
+ return this;
+ }
+ /**
+ * Topic used for receiving response when using in-out pattern.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param replyToTopic the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder replyToTopic(String replyToTopic) {
+ doSetProperty("replyToTopic", replyToTopic);
+ return this;
+ }
+ /**
+ * Each message would be sent with this tag.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param sendTag the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder sendTag(String sendTag) {
+ doSetProperty("sendTag", sendTag);
+ return this;
+ }
+ /**
+ * Whether waiting for send result before routing to next endpoint.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param waitForSendResult the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder waitForSendResult(
+ boolean waitForSendResult) {
+ doSetProperty("waitForSendResult", waitForSendResult);
+ return this;
+ }
+ /**
+ * Whether waiting for send result before routing to next endpoint.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param waitForSendResult the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder waitForSendResult(
+ String waitForSendResult) {
+ doSetProperty("waitForSendResult", waitForSendResult);
+ return this;
+ }
+ /**
+ * Access key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param accessKey the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder accessKey(String accessKey) {
+ doSetProperty("accessKey", accessKey);
+ return this;
+ }
+ /**
+ * Secret key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param secretKey the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointProducerBuilder secretKey(String secretKey) {
+ doSetProperty("secretKey", secretKey);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint producers for the RocketMQ component.
+ */
+ public interface AdvancedRocketMQEndpointProducerBuilder
+ extends
+ EndpointProducerBuilder {
+ default RocketMQEndpointProducerBuilder basic() {
+ return (RocketMQEndpointProducerBuilder) 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
+ * 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.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer (advanced)
+ *
+ * @param lazyStartProducer the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointProducerBuilder lazyStartProducer(
+ boolean lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ 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
+ * 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.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: producer (advanced)
+ *
+ * @param lazyStartProducer the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointProducerBuilder lazyStartProducer(
+ String lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
+ return this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointProducerBuilder requestTimeoutCheckerIntervalMillis(
+ long requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointProducerBuilder requestTimeoutCheckerIntervalMillis(
+ String requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointProducerBuilder requestTimeoutMillis(
+ long requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointProducerBuilder requestTimeoutMillis(
+ String requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ }
+
+ /**
+ * Builder for endpoint for the RocketMQ component.
+ */
+ public interface RocketMQEndpointBuilder
+ extends
+ RocketMQEndpointConsumerBuilder,
+ RocketMQEndpointProducerBuilder {
+ default AdvancedRocketMQEndpointBuilder advanced() {
+ return (AdvancedRocketMQEndpointBuilder) this;
+ }
+ /**
+ * Name server address of RocketMQ cluster.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: localhost:9876
+ * Group: common
+ *
+ * @param namesrvAddr the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointBuilder namesrvAddr(String namesrvAddr) {
+ doSetProperty("namesrvAddr", namesrvAddr);
+ return this;
+ }
+ /**
+ * Access key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param accessKey the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointBuilder accessKey(String accessKey) {
+ doSetProperty("accessKey", accessKey);
+ return this;
+ }
+ /**
+ * Secret key for RocketMQ ACL.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param secretKey the value to set
+ * @return the dsl builder
+ */
+ default RocketMQEndpointBuilder secretKey(String secretKey) {
+ doSetProperty("secretKey", secretKey);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint for the RocketMQ component.
+ */
+ public interface AdvancedRocketMQEndpointBuilder
+ extends
+ AdvancedRocketMQEndpointConsumerBuilder,
+ AdvancedRocketMQEndpointProducerBuilder {
+ default RocketMQEndpointBuilder basic() {
+ return (RocketMQEndpointBuilder) this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointBuilder requestTimeoutCheckerIntervalMillis(
+ long requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Check interval milliseconds of request timeout.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: advanced
+ *
+ * @param requestTimeoutCheckerIntervalMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointBuilder requestTimeoutCheckerIntervalMillis(
+ String requestTimeoutCheckerIntervalMillis) {
+ doSetProperty("requestTimeoutCheckerIntervalMillis", requestTimeoutCheckerIntervalMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointBuilder requestTimeoutMillis(
+ long requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ /**
+ * Timeout milliseconds of receiving response when using in-out pattern.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10000
+ * Group: advanced
+ *
+ * @param requestTimeoutMillis the value to set
+ * @return the dsl builder
+ */
+ default AdvancedRocketMQEndpointBuilder requestTimeoutMillis(
+ String requestTimeoutMillis) {
+ doSetProperty("requestTimeoutMillis", requestTimeoutMillis);
+ return this;
+ }
+ }
+
+ public interface RocketMQBuilders {
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * @return the dsl builder for the headers' name.
+ */
+ default RocketMQHeaderNameBuilder rocketmq() {
+ return RocketMQHeaderNameBuilder.INSTANCE;
+ }
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * Syntax: <code>rocketmq:topicName</code>
+ *
+ * Path parameter: topicName (required)
+ * Topic name of this endpoint.
+ *
+ * @param path topicName
+ * @return the dsl builder
+ */
+ default RocketMQEndpointBuilder rocketmq(String path) {
+ return RocketMQEndpointBuilderFactory.endpointBuilder("rocketmq", path);
+ }
+ /**
+ * RocketMQ (camel-rocketmq)
+ * Send and receive messages from RocketMQ cluster.
+ *
+ * Category: messaging
+ * Since: 3.20
+ * Maven coordinates: org.apache.camel:camel-rocketmq
+ *
+ * Syntax: <code>rocketmq:topicName</code>
+ *
+ * Path parameter: topicName (required)
+ * Topic name of this endpoint.
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path topicName
+ * @return the dsl builder
+ */
+ default RocketMQEndpointBuilder rocketmq(
+ String componentName,
+ String path) {
+ return RocketMQEndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
+ }
+
+ /**
+ * The builder of headers' name for the RocketMQ component.
+ */
+ public static class RocketMQHeaderNameBuilder {
+ /**
+ * The internal instance of the builder used to access to all the
+ * methods representing the name of headers.
+ */
+ private static final RocketMQHeaderNameBuilder INSTANCE = new RocketMQHeaderNameBuilder();
+
+ /**
+ * Topic of message.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQTopic}.
+ */
+ public String rockerMQTopic() {
+ return "RockerMQTopic";
+ }
+
+ /**
+ * Tag of message.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQTag}.
+ */
+ public String rockerMQTag() {
+ return "RockerMQTag";
+ }
+
+ /**
+ * Key of message.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQKey}.
+ */
+ public String rockerMQKey() {
+ return "RockerMQKey";
+ }
+
+ /**
+ * If this header is set, the message will be routed to the topic
+ * specified by this header instead of the origin topic in endpoint.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code RockerMQOverrideTopicName}.
+ */
+ public String rockerMQOverrideTopicName() {
+ return "RockerMQOverrideTopicName";
+ }
+
+ /**
+ * If this header is set, the message's tag will be set to value
+ * specified by this header instead of the sendTag defined in endpoint.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code RockerMQOverrideTag}.
+ */
+ public String rockerMQOverrideTag() {
+ return "RockerMQOverrideTag";
+ }
+
+ /**
+ * Set keys for the message. When using in-out pattern, the value will
+ * be prepended to the generated keys.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: producer
+ *
+ * @return the name of the header {@code RockerMQOverrideMessageKey}.
+ */
+ public String rockerMQOverrideMessageKey() {
+ return "RockerMQOverrideMessageKey";
+ }
+
+ /**
+ * Broker name.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQBrokerName}.
+ */
+ public String rockerMQBrokerName() {
+ return "RockerMQBrokerName";
+ }
+
+ /**
+ * Queue ID.
+ *
+ * The option is a: {@code int} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQQueueId}.
+ */
+ public String rockerMQQueueId() {
+ return "RockerMQQueueId";
+ }
+
+ /**
+ * Store size.
+ *
+ * The option is a: {@code int} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQStoreSize}.
+ */
+ public String rockerMQStoreSize() {
+ return "RockerMQStoreSize";
+ }
+
+ /**
+ * Queue offset.
+ *
+ * The option is a: {@code long} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQQueueOffset}.
+ */
+ public String rockerMQQueueOffset() {
+ return "RockerMQQueueOffset";
+ }
+
+ /**
+ * Sys flag.
+ *
+ * The option is a: {@code int} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQSysFlag}.
+ */
+ public String rockerMQSysFlag() {
+ return "RockerMQSysFlag";
+ }
+
+ /**
+ * Born timestamp.
+ *
+ * The option is a: {@code long} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQBornTimestamp}.
+ */
+ public String rockerMQBornTimestamp() {
+ return "RockerMQBornTimestamp";
+ }
+
+ /**
+ * Born host.
+ *
+ * The option is a: {@code java.net.SocketAddress} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQBornHost}.
+ */
+ public String rockerMQBornHost() {
+ return "RockerMQBornHost";
+ }
+
+ /**
+ * Store timestamp.
+ *
+ * The option is a: {@code long} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQStoreTimestamp}.
+ */
+ public String rockerMQStoreTimestamp() {
+ return "RockerMQStoreTimestamp";
+ }
+
+ /**
+ * Store host.
+ *
+ * The option is a: {@code java.net.SocketAddress} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQStoreHost}.
+ */
+ public String rockerMQStoreHost() {
+ return "RockerMQStoreHost";
+ }
+
+ /**
+ * Msg ID.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQMsgId}.
+ */
+ public String rockerMQMsgId() {
+ return "RockerMQMsgId";
+ }
+
+ /**
+ * Commit log offset.
+ *
+ * The option is a: {@code long} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQCommitLogOffset}.
+ */
+ public String rockerMQCommitLogOffset() {
+ return "RockerMQCommitLogOffset";
+ }
+
+ /**
+ * Body CRC.
+ *
+ * The option is a: {@code int} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQBodyCrc}.
+ */
+ public String rockerMQBodyCrc() {
+ return "RockerMQBodyCrc";
+ }
+
+ /**
+ * Reconsume times.
+ *
+ * The option is a: {@code int} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code RockerMQReconsumeTimes}.
+ */
+ public String rockerMQReconsumeTimes() {
+ return "RockerMQReconsumeTimes";
+ }
+
+ /**
+ * Prepard transaction offset.
+ *
+ * The option is a: {@code long} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code
+ * RockerMQPreparedTransactionOffset}.
+ */
+ public String rockerMQPreparedTransactionOffset() {
+ return "RockerMQPreparedTransactionOffset";
+ }
+ }
+ static RocketMQEndpointBuilder endpointBuilder(
+ String componentName,
+ String path) {
+ class RocketMQEndpointBuilderImpl extends AbstractEndpointBuilder implements RocketMQEndpointBuilder, AdvancedRocketMQEndpointBuilder {
+ public RocketMQEndpointBuilderImpl(String path) {
+ super(componentName, path);
+ }
+ }
+ return new RocketMQEndpointBuilderImpl(path);
+ }
+}
\ No newline at end of file
diff --git a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
index 33c8a492374..8bc66766e28 100644
--- a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
+++ b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
@@ -281,6 +281,7 @@ org.apache.camel.component.rest.openapi.RestOpenApiComponent=camel:rest-openapi
org.apache.camel.component.rest.swagger.RestSwaggerComponent=camel:rest-swagger
org.apache.camel.component.resteasy.ResteasyComponent=camel:resteasy
org.apache.camel.component.robotframework.RobotFrameworkComponent=camel:robotframework
+org.apache.camel.component.rocketmq.RocketMQComponent=camel:rocketmq
org.apache.camel.component.rss.RssComponent=camel:rss
org.apache.camel.component.saga.SagaComponent=camel:saga
org.apache.camel.component.salesforce.SalesforceComponent=camel:salesforce