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 a43d85f CAMEL-17104 - getObject operation support in producer mode
(#6308)
a43d85f is described below
commit a43d85f5c14777a45e4c7dab9107ebc175db6cec
Author: Hokutor <hwca...@huawei.com>
AuthorDate: Wed Oct 20 01:09:35 2021 -0400
CAMEL-17104 - getObject operation support in producer mode (#6308)
* CAMEL-17104 - Get Object operation support in producer mode
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
* CAMEl-17104 - Grammatical correction on exception description
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
* CAMEL-17104 - updated docs
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
* CAMEL-17104 - More doc updates
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
* CAMEL-17104 - adding license headers
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
* CAMEL-17104 - checkstyle corrections in import statements
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
* CAMEL-17104 - renamed test method
Co-Authored-By: Reji Mathews <contactr...@gmail.com>
Co-authored-by: Reji Mathews <contactr...@gmail.com>
---
.../camel-huawei/camel-huaweicloud-obs/pom.xml | 6 ++
.../huaweicloud/obs/OBSEndpointConfigurer.java | 6 ++
.../huaweicloud/obs/OBSEndpointUriFactory.java | 3 +-
.../component/huaweicloud/obs/hwcloud-obs.json | 1 +
.../src/main/docs/hwcloud-obs-component.adoc | 5 +
.../component/huaweicloud/obs/OBSConsumer.java | 26 +----
.../component/huaweicloud/obs/OBSEndpoint.java | 12 +++
.../component/huaweicloud/obs/OBSProducer.java | 35 ++++++
.../camel/component/huaweicloud/obs/OBSUtils.java | 40 +++++++
.../huaweicloud/obs/constants/OBSOperations.java | 1 +
.../huaweicloud/obs/constants/OBSProperties.java | 1 +
.../obs/models/ClientConfigurations.java | 9 ++
.../huaweicloud/obs/GetObjectFunctionalTest.java | 74 +++++++++++++
.../component/huaweicloud/obs/GetObjectTest.java | 119 +++++++++++++++++++++
.../src/test/resources/files/test_file.txt | 1 +
.../builder/endpoint/EndpointBuilderFactory.java | 56 +++++-----
.../camel/builder/endpoint/EndpointBuilders.java | 56 +++++-----
.../endpoint/dsl/OBSEndpointBuilderFactory.java | 42 ++++++++
18 files changed, 411 insertions(+), 82 deletions(-)
diff --git a/components/camel-huawei/camel-huaweicloud-obs/pom.xml
b/components/camel-huawei/camel-huaweicloud-obs/pom.xml
index 0a6af70..4aa95b3 100644
--- a/components/camel-huawei/camel-huaweicloud-obs/pom.xml
+++ b/components/camel-huawei/camel-huaweicloud-obs/pom.xml
@@ -54,6 +54,12 @@
</dependency>
<dependency>
+ <groupId>com.squareup.okhttp3</groupId>
+ <artifactId>okhttp</artifactId>
+ <version>${squareup-okhttp-version}</version>
+ </dependency>
+
+ <dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>${gson-version}</version>
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
index a6741c1..59f29a0 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
@@ -61,6 +61,8 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
case "maxMessagesPerPoll":
target.setMaxMessagesPerPoll(property(camelContext, int.class, value)); return
true;
case "moveafterread":
case "moveAfterRead": target.setMoveAfterRead(property(camelContext,
boolean.class, value)); return true;
+ case "objectname":
+ case "objectName": target.setObjectName(property(camelContext,
java.lang.String.class, value)); return true;
case "pollstrategy":
case "pollStrategy": target.setPollStrategy(property(camelContext,
org.apache.camel.spi.PollingConsumerPollStrategy.class, value)); return true;
case "prefix": target.setPrefix(property(camelContext,
java.lang.String.class, value)); return true;
@@ -141,6 +143,8 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
case "maxMessagesPerPoll": return int.class;
case "moveafterread":
case "moveAfterRead": return boolean.class;
+ case "objectname":
+ case "objectName": return java.lang.String.class;
case "pollstrategy":
case "pollStrategy": return
org.apache.camel.spi.PollingConsumerPollStrategy.class;
case "prefix": return java.lang.String.class;
@@ -222,6 +226,8 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
case "maxMessagesPerPoll": return target.getMaxMessagesPerPoll();
case "moveafterread":
case "moveAfterRead": return target.isMoveAfterRead();
+ case "objectname":
+ case "objectName": return target.getObjectName();
case "pollstrategy":
case "pollStrategy": return target.getPollStrategy();
case "prefix": return target.getPrefix();
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
index c02602c..c3724ef 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
@@ -20,7 +20,7 @@ public class OBSEndpointUriFactory extends
org.apache.camel.support.component.En
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(41);
+ Set<String> props = new HashSet<>(42);
props.add("backoffMultiplier");
props.add("bucketName");
props.add("destinationBucket");
@@ -59,6 +59,7 @@ public class OBSEndpointUriFactory extends
org.apache.camel.support.component.En
props.add("accessKey");
props.add("deleteAfterRead");
props.add("proxyUser");
+ props.add("objectName");
props.add("region");
props.add("operation");
props.add("exceptionHandler");
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
index b839f98..d4f3218 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
@@ -30,6 +30,7 @@
"operation": { "kind": "path", "displayName": "Operation", "group":
"producer", "label": "producer", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Operation to be performed"
},
"bucketName": { "kind": "parameter", "displayName": "Bucket Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Name of bucket to perform
operation on" },
"endpoint": { "kind": "parameter", "displayName": "Endpoint url", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "OBS url. Carries higher precedence than
region parameter based client initialization" },
+ "objectName": { "kind": "parameter", "displayName": "Object Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Name of object to perform
operation with" },
"region": { "kind": "parameter", "displayName": "Service region", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "OBS service region. This is lower
precedence than endpoint based configuration" },
"bridgeErrorHandler": { "kind": "parameter", "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 m [...]
"deleteAfterRead": { "kind": "parameter", "displayName": "Delete after
read", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": false, "description":
"Determines if objects should be deleted after it has been retrieved" },
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/docs/hwcloud-obs-component.adoc
b/components/camel-huawei/camel-huaweicloud-obs/src/main/docs/hwcloud-obs-component.adoc
index 3b2e64c..35b1072 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/docs/hwcloud-obs-component.adoc
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/docs/hwcloud-obs-component.adoc
@@ -64,6 +64,8 @@ include::partial$component-endpoint-options.adoc[]
|`CamelHwCloudObsBucketLocation` |`String` | Bucket location when creating a
new bucket
+|`CamelHwCloudObsObjectName` |`String` | Name of the object to be used in
operation
+
|=======================================================================
If any of the above properties are set, they will override their corresponding
query parameter.
@@ -86,6 +88,8 @@ If any of the above properties are set, they will override
their corresponding q
|`CamelHwCloudObsBucketName` |`String` | Name of the bucket where object is
contained
+|`CamelHwCloudObsObjectName` |`String` | Name of the object with which the
operation is to be performed
+
|`CamelHwCloudObsObjectKey` |`String` | The key that the object is stored under
|`CamelHwCloudObsLastModified` |`String` | The date and time that the object
was last modified
@@ -111,6 +115,7 @@ If any of the above properties are set, they will override
their corresponding q
- checkBucketExists - `bucketName` parameter is *required*
- getBucketMetadata - `bucketName` parameter is *required*
- listObjects - `bucketName` parameter is *required*
+- getObject - `bucketName` and `objectName` parameters are *required*
=== Passing Options Through Exchange Body
There are many options that can be submited to the `createBucket` and
`listObjects` operations, so they can be passed through the exchange body.
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSConsumer.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSConsumer.java
index 84f4958..745947f 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSConsumer.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSConsumer.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.huaweicloud.obs;
-import java.io.IOException;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
@@ -35,10 +34,7 @@ import org.apache.camel.AsyncCallback;
import org.apache.camel.Exchange;
import org.apache.camel.ExchangePropertyKey;
import org.apache.camel.ExtendedExchange;
-import org.apache.camel.Message;
import org.apache.camel.Processor;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.component.huaweicloud.obs.constants.OBSConstants;
import org.apache.camel.component.huaweicloud.obs.constants.OBSHeaders;
import org.apache.camel.spi.Synchronization;
import org.apache.camel.support.ScheduledBatchPollingConsumer;
@@ -236,28 +232,8 @@ public class OBSConsumer extends
ScheduledBatchPollingConsumer {
public Exchange createExchange(ObsObject obsObject) {
Exchange exchange = createExchange(true);
exchange.setPattern(endpoint.getExchangePattern());
- Message message = exchange.getIn();
- // set exchange body to a byte array of object contents
- try {
- message.setBody(OBSUtils.toBytes(obsObject.getObjectContent()));
- } catch (IOException e) {
- throw new RuntimeCamelException(e);
- }
-
- // set all the message headers
- message.setHeader(OBSHeaders.BUCKET_NAME, obsObject.getBucketName());
- message.setHeader(OBSHeaders.OBJECT_KEY, obsObject.getObjectKey());
- message.setHeader(OBSHeaders.LAST_MODIFIED,
obsObject.getMetadata().getLastModified());
- message.setHeader(Exchange.CONTENT_LENGTH,
obsObject.getMetadata().getContentLength());
- message.setHeader(Exchange.CONTENT_TYPE,
obsObject.getMetadata().getContentType());
- message.setHeader(OBSHeaders.ETAG, obsObject.getMetadata().getEtag());
- message.setHeader(OBSHeaders.CONTENT_MD5,
obsObject.getMetadata().getContentMd5());
- if (obsObject.getObjectKey().endsWith("/")) {
- message.setHeader(OBSHeaders.OBJECT_TYPE, OBSConstants.FOLDER);
- } else {
- message.setHeader(OBSHeaders.OBJECT_TYPE, OBSConstants.FILE);
- }
+ OBSUtils.mapObsObject(exchange, obsObject);
return exchange;
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSEndpoint.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSEndpoint.java
index 84bb750..e56a7f9 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSEndpoint.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSEndpoint.java
@@ -94,6 +94,10 @@ public class OBSEndpoint extends ScheduledPollEndpoint {
@Metadata(required = false)
private String bucketName;
+ @UriParam(description = "Name of object to perform operation with",
displayName = "Object Name")
+ @Metadata(required = false)
+ private String objectName;
+
@UriParam(description = "Location of bucket when creating a new bucket",
displayName = "Bucket Location",
label = "producer")
@Metadata(required = false)
@@ -335,6 +339,14 @@ public class OBSEndpoint extends ScheduledPollEndpoint {
this.maxMessagesPerPoll = maxMessagesPerPoll;
}
+ public String getObjectName() {
+ return objectName;
+ }
+
+ public void setObjectName(String objectName) {
+ this.objectName = objectName;
+ }
+
/**
* Initialize and return a new OBS Client
*
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSProducer.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSProducer.java
index c222ced..b1bb53b 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSProducer.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSProducer.java
@@ -91,6 +91,9 @@ public class OBSProducer extends DefaultProducer {
case OBSOperations.LIST_OBJECTS:
listObjects(exchange, clientConfigurations);
break;
+ case OBSOperations.GET_OBJECT:
+ getObject(exchange, clientConfigurations);
+ break;
default:
throw new UnsupportedOperationException(
String.format("%s is not a supported operation",
clientConfigurations.getOperation()));
@@ -98,6 +101,29 @@ public class OBSProducer extends DefaultProducer {
}
/**
+ * downloads an object from remote OBS bucket
+ *
+ * @param exchange
+ * @param clientConfigurations
+ */
+ private void getObject(Exchange exchange, ClientConfigurations
clientConfigurations) {
+ if (ObjectHelper.isEmpty(clientConfigurations.getBucketName()) ||
+ ObjectHelper.isEmpty(clientConfigurations.getObjectName())) {
+ throw new IllegalArgumentException("Bucket and object names are
mandatory to get objects");
+ }
+
+ LOG.debug("Downloading remote obs object {} from bucket {}",
clientConfigurations.getObjectName(),
+ clientConfigurations.getBucketLocation());
+
+ ObsObject obsObject = obsClient
+ .getObject(clientConfigurations.getBucketName(),
clientConfigurations.getObjectName());
+
+ LOG.debug("Successfully downloaded obs object {}",
clientConfigurations.getObjectName());
+
+ OBSUtils.mapObsObject(exchange, obsObject);
+ }
+
+ /**
* Perform list buckets operation
*
* @param exchange
@@ -301,5 +327,14 @@ public class OBSProducer extends DefaultProducer {
? (String)
exchange.getProperty(OBSProperties.BUCKET_LOCATION)
: endpoint.getBucketLocation());
}
+
+ // checking for optional object name (exchange overrides endpoint
bucketLocation if both are provided)
+ if
(ObjectHelper.isNotEmpty(exchange.getProperty(OBSProperties.OBJECT_NAME))
+ || ObjectHelper.isNotEmpty(endpoint.getObjectName())) {
+ clientConfigurations.setObjectName(
+
ObjectHelper.isNotEmpty(exchange.getProperty(OBSProperties.OBJECT_NAME))
+ ? (String)
exchange.getProperty(OBSProperties.OBJECT_NAME)
+ : endpoint.getObjectName());
+ }
}
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSUtils.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSUtils.java
index e1733b6..ba4b22c 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSUtils.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/OBSUtils.java
@@ -20,6 +20,12 @@ import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
+import com.obs.services.model.ObsObject;
+import org.apache.camel.Exchange;
+import org.apache.camel.Message;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.component.huaweicloud.obs.constants.OBSConstants;
+import org.apache.camel.component.huaweicloud.obs.constants.OBSHeaders;
import org.apache.camel.util.IOHelper;
public final class OBSUtils {
@@ -38,4 +44,38 @@ public final class OBSUtils {
IOHelper.copy(IOHelper.buffered(stream), bos);
return bos.toByteArray();
}
+
+ /**
+ * maps the Obs object along with all its meta-data into exchange
+ *
+ * @param exchange
+ * @param obsObject
+ */
+ public static void mapObsObject(Exchange exchange, ObsObject obsObject) {
+ Message message = exchange.getIn();
+
+ // set exchange body to a byte array of object contents
+ try {
+ message.setBody(OBSUtils.toBytes(obsObject.getObjectContent()));
+ } catch (IOException e) {
+ throw new RuntimeCamelException(e);
+ }
+
+ // set all the message headers
+ message.setHeader(OBSHeaders.BUCKET_NAME, obsObject.getBucketName());
+ message.setHeader(OBSHeaders.OBJECT_KEY, obsObject.getObjectKey());
+ message.setHeader(OBSHeaders.LAST_MODIFIED,
obsObject.getMetadata().getLastModified());
+ message.setHeader(Exchange.CONTENT_LENGTH,
obsObject.getMetadata().getContentLength());
+ message.setHeader(Exchange.CONTENT_TYPE,
obsObject.getMetadata().getContentType());
+ message.setHeader(OBSHeaders.ETAG, obsObject.getMetadata().getEtag());
+ message.setHeader(OBSHeaders.CONTENT_MD5,
obsObject.getMetadata().getContentMd5());
+
+ message.setHeader(Exchange.FILE_NAME, obsObject.getObjectKey());
+
+ if (obsObject.getObjectKey().endsWith("/")) {
+ message.setHeader(OBSHeaders.OBJECT_TYPE, OBSConstants.FOLDER);
+ } else {
+ message.setHeader(OBSHeaders.OBJECT_TYPE, OBSConstants.FILE);
+ }
+ }
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSOperations.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSOperations.java
index a8331ee..d9fd239 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSOperations.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSOperations.java
@@ -26,6 +26,7 @@ public final class OBSOperations {
public static final String CHECK_BUCKET_EXISTS = "checkBucketExists";
public static final String GET_BUCKET_METADATA = "getBucketMetadata";
public static final String LIST_OBJECTS = "listObjects";
+ public static final String GET_OBJECT = "getObject";
private OBSOperations() {
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSProperties.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSProperties.java
index 1de77b5..a1f2a0e 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSProperties.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/constants/OBSProperties.java
@@ -24,6 +24,7 @@ public final class OBSProperties {
public static final String BUCKET_NAME = "CamelHwCloudObsBucketName";
public static final String BUCKET_LOCATION =
"CamelHwCloudObsBucketLocation";
public static final String BUCKET_EXISTS = "CamelHwCloudObsBucketExists";
+ public static final String OBJECT_NAME = "CamelHwCloudObsObjectName";
private OBSProperties() {
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/models/ClientConfigurations.java
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/models/ClientConfigurations.java
index beecb20..7b1f625 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/models/ClientConfigurations.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/main/java/org/apache/camel/component/huaweicloud/obs/models/ClientConfigurations.java
@@ -24,6 +24,7 @@ public class ClientConfigurations {
private String operation;
private String bucketName;
private String bucketLocation;
+ private String objectName;
public ClientConfigurations() {
}
@@ -51,4 +52,12 @@ public class ClientConfigurations {
public void setBucketLocation(String bucketLocation) {
this.bucketLocation = bucketLocation;
}
+
+ public String getObjectName() {
+ return objectName;
+ }
+
+ public void setObjectName(String objectName) {
+ this.objectName = objectName;
+ }
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/GetObjectFunctionalTest.java
b/components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/GetObjectFunctionalTest.java
new file mode 100644
index 0000000..5d61865
--- /dev/null
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/GetObjectFunctionalTest.java
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.obs;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.huaweicloud.obs.constants.OBSProperties;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit5.CamelTestSupport;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class GetObjectFunctionalTest extends CamelTestSupport {
+
+ private static final String ACCESS_KEY = "replace_this_with_access_key";
+ private static final String SECRET_KEY = "replace_this_with_secret_key";
+ private static final String REGION = "replace_this_with_region";
+
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ public void configure() throws Exception {
+ from("direct:get_object")
+ .setProperty(OBSProperties.BUCKET_NAME,
constant("reji-test"))
+ .setProperty(OBSProperties.OBJECT_NAME,
constant("test_file.txt"))
+ .to("hwcloud-obs:getObject?" +
+ "accessKey=" + ACCESS_KEY +
+ "&secretKey=" + SECRET_KEY +
+ "®ion=" + REGION +
+ "&ignoreSslVerification=true")
+ .log("Get object successful")
+ .to("log:LOG?showAll=true")
+ .to("mock:get_object_result");
+ }
+ };
+ }
+
+ /**
+ * The following test cases should be manually enabled to perform test
against the actual HuaweiCloud OBS server
+ * with real user credentials. To perform this test, manually comment out
the @Ignore annotation and enter relevant
+ * service parameters in the placeholders above (static variables of this
test class)
+ *
+ * @throws Exception
+ */
+ @Disabled("Manually enable this once you configure the parameters in the
placeholders above")
+ @Test
+ public void testGetObjectFunctionalTest() throws Exception {
+ MockEndpoint mock = getMockEndpoint("mock:get_object_result");
+ mock.expectedMinimumMessageCount(1);
+ template.sendBody("direct:get_object", null);
+ Exchange responseExchange = mock.getExchanges().get(0);
+
+ mock.assertIsSatisfied();
+
+ assertNotNull(responseExchange.getIn().getBody(String.class));
+ assertTrue(responseExchange.getIn().getBody(String.class).length() >
0);
+ }
+}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/GetObjectTest.java
b/components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/GetObjectTest.java
new file mode 100644
index 0000000..ac03005
--- /dev/null
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/GetObjectTest.java
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.obs;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.util.Date;
+
+import com.obs.services.ObsClient;
+import com.obs.services.model.ObjectMetadata;
+import com.obs.services.model.ObsObject;
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.huaweicloud.common.models.ServiceKeys;
+import org.apache.camel.component.huaweicloud.obs.constants.OBSHeaders;
+import org.apache.camel.component.huaweicloud.obs.constants.OBSProperties;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit5.CamelTestSupport;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+public class GetObjectTest extends CamelTestSupport {
+
+ private static final Logger LOG =
LoggerFactory.getLogger(GetObjectTest.class.getName());
+
+ TestConfiguration testConfiguration = new TestConfiguration();
+
+ String bucketName = "reji-test";
+ String objectName = "test_file.txt";
+
+ @BindToRegistry("obsClient")
+ ObsClient mockClient = Mockito.mock(ObsClient.class);
+
+ @BindToRegistry("serviceKeys")
+ ServiceKeys serviceKeys = new ServiceKeys(
+ testConfiguration.getProperty("accessKey"),
+ testConfiguration.getProperty("secretKey"));
+
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:get_object")
+ .setProperty(OBSProperties.BUCKET_NAME,
constant(bucketName))
+ .setProperty(OBSProperties.OBJECT_NAME,
constant(objectName))
+ .to("hwcloud-obs:getObject?" +
+ "accessKey=" +
testConfiguration.getProperty("accessKey") +
+ "&secretKey=" +
testConfiguration.getProperty("secretKey") +
+ "®ion=" +
testConfiguration.getProperty("region") +
+ "&ignoreSslVerification=true" +
+ "&obsClient=#obsClient")
+ .log("Get object successful")
+ .to("mock:get_object_result");
+ }
+ };
+ }
+
+ @Test
+ public void testGetObject() throws Exception {
+
+ ObsObject response = new ObsObject();
+ response.setBucketName(bucketName);
+ response.setObjectKey(objectName);
+
+ File initialFile = new File("src/test/resources/files/test_file.txt");
+ InputStream stream = new FileInputStream(initialFile);
+ response.setObjectContent(stream);
+
+ Date testDate = new Date();
+
+ ObjectMetadata metadata = new ObjectMetadata();
+ metadata.setLastModified(testDate);
+ metadata.setContentLength(9L);
+ metadata.setContentType("text/plain");
+ metadata.setEtag("eb733a00c0c9d336e65691a37ab54293");
+ metadata.setContentMd5("63M6AMDJ0zbmVpGjerVCkw==");
+ response.setMetadata(metadata);
+
+ Mockito.when(mockClient.getObject(bucketName,
objectName)).thenReturn(response);
+
+ MockEndpoint mock = getMockEndpoint("mock:get_object_result");
+ mock.expectedMinimumMessageCount(1);
+ template.sendBody("direct:get_object", "dummy");
+ Exchange responseExchange = mock.getExchanges().get(0);
+
+ mock.assertIsSatisfied();
+
+ assertEquals(9L,
responseExchange.getIn().getHeader(Exchange.CONTENT_LENGTH));
+ assertEquals("text/plain",
responseExchange.getIn().getHeader(Exchange.CONTENT_TYPE));
+ assertEquals("eb733a00c0c9d336e65691a37ab54293",
responseExchange.getIn().getHeader(OBSHeaders.ETAG));
+ assertEquals("63M6AMDJ0zbmVpGjerVCkw==",
responseExchange.getIn().getHeader(OBSHeaders.CONTENT_MD5));
+ assertEquals(testDate,
responseExchange.getIn().getHeader(OBSHeaders.LAST_MODIFIED));
+
+ assertEquals(bucketName,
responseExchange.getIn().getHeader(OBSHeaders.BUCKET_NAME));
+ assertEquals(objectName,
responseExchange.getIn().getHeader(OBSHeaders.OBJECT_KEY));
+ assertEquals(objectName,
responseExchange.getIn().getHeader(Exchange.FILE_NAME));
+
+ }
+}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/test/resources/files/test_file.txt
b/components/camel-huawei/camel-huaweicloud-obs/src/test/resources/files/test_file.txt
new file mode 100644
index 0000000..0aa6fb5
--- /dev/null
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/test/resources/files/test_file.txt
@@ -0,0 +1 @@
+test data
\ No newline at end of file
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index dd07f1a..5002e72 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -28,13 +28,11 @@ import javax.annotation.Generated;
@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
public interface EndpointBuilderFactory
extends
-
org.apache.camel.builder.endpoint.dsl.AMQPEndpointBuilderFactory.AMQPBuilders,
-
org.apache.camel.builder.endpoint.dsl.AS2EndpointBuilderFactory.AS2Builders,
-
org.apache.camel.builder.endpoint.dsl.AWS2EC2EndpointBuilderFactory.AWS2EC2Builders,
-
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3Builders,
org.apache.camel.builder.endpoint.dsl.ActiveMQEndpointBuilderFactory.ActiveMQBuilders,
org.apache.camel.builder.endpoint.dsl.AhcEndpointBuilderFactory.AhcBuilders,
+
org.apache.camel.builder.endpoint.dsl.AMQPEndpointBuilderFactory.AMQPBuilders,
org.apache.camel.builder.endpoint.dsl.ArangoDbEndpointBuilderFactory.ArangoDbBuilders,
+
org.apache.camel.builder.endpoint.dsl.AS2EndpointBuilderFactory.AS2Builders,
org.apache.camel.builder.endpoint.dsl.AsteriskEndpointBuilderFactory.AsteriskBuilders,
org.apache.camel.builder.endpoint.dsl.Athena2EndpointBuilderFactory.Athena2Builders,
org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory.AtlasMapBuilders,
@@ -48,16 +46,16 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.AtomixSetEndpointBuilderFactory.AtomixSetBuilders,
org.apache.camel.builder.endpoint.dsl.AtomixValueEndpointBuilderFactory.AtomixValueBuilders,
org.apache.camel.builder.endpoint.dsl.AvroEndpointBuilderFactory.AvroBuilders,
+
org.apache.camel.builder.endpoint.dsl.AWS2EC2EndpointBuilderFactory.AWS2EC2Builders,
+
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3Builders,
org.apache.camel.builder.endpoint.dsl.BeanEndpointBuilderFactory.BeanBuilders,
-
org.apache.camel.builder.endpoint.dsl.BeanValidatorEndpointBuilderFactory.BeanValidatorBuilders,
org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory.BeanstalkBuilders,
+
org.apache.camel.builder.endpoint.dsl.BeanValidatorEndpointBuilderFactory.BeanValidatorBuilders,
org.apache.camel.builder.endpoint.dsl.BlobEndpointBuilderFactory.BlobBuilders,
org.apache.camel.builder.endpoint.dsl.BonitaEndpointBuilderFactory.BonitaBuilders,
org.apache.camel.builder.endpoint.dsl.BoxEndpointBuilderFactory.BoxBuilders,
org.apache.camel.builder.endpoint.dsl.BraintreeEndpointBuilderFactory.BraintreeBuilders,
org.apache.camel.builder.endpoint.dsl.BrowseEndpointBuilderFactory.BrowseBuilders,
-
org.apache.camel.builder.endpoint.dsl.CMEndpointBuilderFactory.CMBuilders,
-
org.apache.camel.builder.endpoint.dsl.CMISEndpointBuilderFactory.CMISBuilders,
org.apache.camel.builder.endpoint.dsl.CaffeineCacheEndpointBuilderFactory.CaffeineCacheBuilders,
org.apache.camel.builder.endpoint.dsl.CaffeineLoadCacheEndpointBuilderFactory.CaffeineLoadCacheBuilders,
org.apache.camel.builder.endpoint.dsl.CassandraEndpointBuilderFactory.CassandraBuilders,
@@ -66,20 +64,20 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.CinderEndpointBuilderFactory.CinderBuilders,
org.apache.camel.builder.endpoint.dsl.ClassEndpointBuilderFactory.ClassBuilders,
org.apache.camel.builder.endpoint.dsl.ClientEndpointBuilderFactory.ClientBuilders,
+
org.apache.camel.builder.endpoint.dsl.CMEndpointBuilderFactory.CMBuilders,
+
org.apache.camel.builder.endpoint.dsl.CMISEndpointBuilderFactory.CMISBuilders,
org.apache.camel.builder.endpoint.dsl.CoAPEndpointBuilderFactory.CoAPBuilders,
org.apache.camel.builder.endpoint.dsl.CometdEndpointBuilderFactory.CometdBuilders,
org.apache.camel.builder.endpoint.dsl.ConsulEndpointBuilderFactory.ConsulBuilders,
org.apache.camel.builder.endpoint.dsl.ControlBusEndpointBuilderFactory.ControlBusBuilders,
org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory.CordaBuilders,
org.apache.camel.builder.endpoint.dsl.CosmosDbEndpointBuilderFactory.CosmosDbBuilders,
-
org.apache.camel.builder.endpoint.dsl.CouchDbEndpointBuilderFactory.CouchDbBuilders,
org.apache.camel.builder.endpoint.dsl.CouchbaseEndpointBuilderFactory.CouchbaseBuilders,
+
org.apache.camel.builder.endpoint.dsl.CouchDbEndpointBuilderFactory.CouchDbBuilders,
org.apache.camel.builder.endpoint.dsl.CronEndpointBuilderFactory.CronBuilders,
org.apache.camel.builder.endpoint.dsl.Cw2EndpointBuilderFactory.Cw2Builders,
org.apache.camel.builder.endpoint.dsl.CxfEndpointBuilderFactory.CxfBuilders,
org.apache.camel.builder.endpoint.dsl.CxfRsEndpointBuilderFactory.CxfRsBuilders,
-
org.apache.camel.builder.endpoint.dsl.DJLEndpointBuilderFactory.DJLBuilders,
-
org.apache.camel.builder.endpoint.dsl.DMSEndpointBuilderFactory.DMSBuilders,
org.apache.camel.builder.endpoint.dsl.DataFormatEndpointBuilderFactory.DataFormatBuilders,
org.apache.camel.builder.endpoint.dsl.DataLakeEndpointBuilderFactory.DataLakeBuilders,
org.apache.camel.builder.endpoint.dsl.DataSetEndpointBuilderFactory.DataSetBuilders,
@@ -96,22 +94,24 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.DirectVmEndpointBuilderFactory.DirectVmBuilders,
org.apache.camel.builder.endpoint.dsl.DisruptorEndpointBuilderFactory.DisruptorBuilders,
org.apache.camel.builder.endpoint.dsl.DisruptorVmEndpointBuilderFactory.DisruptorVmBuilders,
+
org.apache.camel.builder.endpoint.dsl.DJLEndpointBuilderFactory.DJLBuilders,
+
org.apache.camel.builder.endpoint.dsl.DMSEndpointBuilderFactory.DMSBuilders,
org.apache.camel.builder.endpoint.dsl.DnsEndpointBuilderFactory.DnsBuilders,
org.apache.camel.builder.endpoint.dsl.DockerEndpointBuilderFactory.DockerBuilders,
org.apache.camel.builder.endpoint.dsl.DozerEndpointBuilderFactory.DozerBuilders,
org.apache.camel.builder.endpoint.dsl.DrillEndpointBuilderFactory.DrillBuilders,
org.apache.camel.builder.endpoint.dsl.DropboxEndpointBuilderFactory.DropboxBuilders,
org.apache.camel.builder.endpoint.dsl.ECS2EndpointBuilderFactory.ECS2Builders,
-
org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory.EKS2Builders,
org.apache.camel.builder.endpoint.dsl.EhcacheEndpointBuilderFactory.EhcacheBuilders,
+
org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory.EKS2Builders,
org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory.ElasticsearchBuilders,
org.apache.camel.builder.endpoint.dsl.ElsqlEndpointBuilderFactory.ElsqlBuilders,
org.apache.camel.builder.endpoint.dsl.EtcdKeysEndpointBuilderFactory.EtcdKeysBuilders,
org.apache.camel.builder.endpoint.dsl.EtcdStatsEndpointBuilderFactory.EtcdStatsBuilders,
org.apache.camel.builder.endpoint.dsl.EtcdWatchEndpointBuilderFactory.EtcdWatchBuilders,
+
org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory.EventbridgeBuilders,
org.apache.camel.builder.endpoint.dsl.EventEndpointBuilderFactory.EventBuilders,
org.apache.camel.builder.endpoint.dsl.EventHubsEndpointBuilderFactory.EventHubsBuilders,
-
org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory.EventbridgeBuilders,
org.apache.camel.builder.endpoint.dsl.ExecEndpointBuilderFactory.ExecBuilders,
org.apache.camel.builder.endpoint.dsl.FacebookEndpointBuilderFactory.FacebookBuilders,
org.apache.camel.builder.endpoint.dsl.FhirEndpointBuilderFactory.FhirBuilders,
@@ -147,7 +147,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory.GridFsBuilders,
org.apache.camel.builder.endpoint.dsl.GrpcEndpointBuilderFactory.GrpcBuilders,
org.apache.camel.builder.endpoint.dsl.GuavaEventBusEndpointBuilderFactory.GuavaEventBusBuilders,
-
org.apache.camel.builder.endpoint.dsl.HBaseEndpointBuilderFactory.HBaseBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastInstanceEndpointBuilderFactory.HazelcastInstanceBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastListEndpointBuilderFactory.HazelcastListBuilders,
@@ -159,12 +158,11 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.HazelcastSedaEndpointBuilderFactory.HazelcastSedaBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastSetEndpointBuilderFactory.HazelcastSetBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastTopicEndpointBuilderFactory.HazelcastTopicBuilders,
+
org.apache.camel.builder.endpoint.dsl.HBaseEndpointBuilderFactory.HBaseBuilders,
org.apache.camel.builder.endpoint.dsl.HdfsEndpointBuilderFactory.HdfsBuilders,
org.apache.camel.builder.endpoint.dsl.HttpEndpointBuilderFactory.HttpBuilders,
org.apache.camel.builder.endpoint.dsl.IAM2EndpointBuilderFactory.IAM2Builders,
org.apache.camel.builder.endpoint.dsl.IAMEndpointBuilderFactory.IAMBuilders,
-
org.apache.camel.builder.endpoint.dsl.IOTAEndpointBuilderFactory.IOTABuilders,
-
org.apache.camel.builder.endpoint.dsl.IPFSEndpointBuilderFactory.IPFSBuilders,
org.apache.camel.builder.endpoint.dsl.IgniteCacheEndpointBuilderFactory.IgniteCacheBuilders,
org.apache.camel.builder.endpoint.dsl.IgniteComputeEndpointBuilderFactory.IgniteComputeBuilders,
org.apache.camel.builder.endpoint.dsl.IgniteEventsEndpointBuilderFactory.IgniteEventsBuilders,
@@ -176,36 +174,38 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.InfinispanEmbeddedEndpointBuilderFactory.InfinispanEmbeddedBuilders,
org.apache.camel.builder.endpoint.dsl.InfinispanRemoteEndpointBuilderFactory.InfinispanRemoteBuilders,
org.apache.camel.builder.endpoint.dsl.InfluxDbEndpointBuilderFactory.InfluxDbBuilders,
+
org.apache.camel.builder.endpoint.dsl.IOTAEndpointBuilderFactory.IOTABuilders,
+
org.apache.camel.builder.endpoint.dsl.IPFSEndpointBuilderFactory.IPFSBuilders,
org.apache.camel.builder.endpoint.dsl.IrcEndpointBuilderFactory.IrcBuilders,
org.apache.camel.builder.endpoint.dsl.IronMQEndpointBuilderFactory.IronMQBuilders,
org.apache.camel.builder.endpoint.dsl.JBPMEndpointBuilderFactory.JBPMBuilders,
org.apache.camel.builder.endpoint.dsl.JCacheEndpointBuilderFactory.JCacheBuilders,
-
org.apache.camel.builder.endpoint.dsl.JGroupsEndpointBuilderFactory.JGroupsBuilders,
-
org.apache.camel.builder.endpoint.dsl.JGroupsRaftEndpointBuilderFactory.JGroupsRaftBuilders,
-
org.apache.camel.builder.endpoint.dsl.JMXEndpointBuilderFactory.JMXBuilders,
-
org.apache.camel.builder.endpoint.dsl.JSR356WebSocketEndpointBuilderFactory.JSR356WebSocketBuilders,
org.apache.camel.builder.endpoint.dsl.JcloudsEndpointBuilderFactory.JcloudsBuilders,
org.apache.camel.builder.endpoint.dsl.JcrEndpointBuilderFactory.JcrBuilders,
org.apache.camel.builder.endpoint.dsl.JdbcEndpointBuilderFactory.JdbcBuilders,
org.apache.camel.builder.endpoint.dsl.JettyHttpEndpointBuilderFactory.JettyHttpBuilders,
+
org.apache.camel.builder.endpoint.dsl.JGroupsEndpointBuilderFactory.JGroupsBuilders,
+
org.apache.camel.builder.endpoint.dsl.JGroupsRaftEndpointBuilderFactory.JGroupsRaftBuilders,
org.apache.camel.builder.endpoint.dsl.JingEndpointBuilderFactory.JingBuilders,
org.apache.camel.builder.endpoint.dsl.JiraEndpointBuilderFactory.JiraBuilders,
org.apache.camel.builder.endpoint.dsl.JmsEndpointBuilderFactory.JmsBuilders,
+
org.apache.camel.builder.endpoint.dsl.JMXEndpointBuilderFactory.JMXBuilders,
org.apache.camel.builder.endpoint.dsl.JoltEndpointBuilderFactory.JoltBuilders,
org.apache.camel.builder.endpoint.dsl.JooqEndpointBuilderFactory.JooqBuilders,
org.apache.camel.builder.endpoint.dsl.JpaEndpointBuilderFactory.JpaBuilders,
org.apache.camel.builder.endpoint.dsl.JsltEndpointBuilderFactory.JsltBuilders,
+
org.apache.camel.builder.endpoint.dsl.JsonataEndpointBuilderFactory.JsonataBuilders,
org.apache.camel.builder.endpoint.dsl.JsonPatchEndpointBuilderFactory.JsonPatchBuilders,
org.apache.camel.builder.endpoint.dsl.JsonValidatorEndpointBuilderFactory.JsonValidatorBuilders,
-
org.apache.camel.builder.endpoint.dsl.JsonataEndpointBuilderFactory.JsonataBuilders,
+
org.apache.camel.builder.endpoint.dsl.JSR356WebSocketEndpointBuilderFactory.JSR356WebSocketBuilders,
org.apache.camel.builder.endpoint.dsl.Jt400EndpointBuilderFactory.Jt400Builders,
-
org.apache.camel.builder.endpoint.dsl.KMS2EndpointBuilderFactory.KMS2Builders,
org.apache.camel.builder.endpoint.dsl.KafkaEndpointBuilderFactory.KafkaBuilders,
org.apache.camel.builder.endpoint.dsl.KameletEndpointBuilderFactory.KameletBuilders,
org.apache.camel.builder.endpoint.dsl.KameletReifyEndpointBuilderFactory.KameletReifyBuilders,
org.apache.camel.builder.endpoint.dsl.KeystoneEndpointBuilderFactory.KeystoneBuilders,
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.Kinesis2Builders,
org.apache.camel.builder.endpoint.dsl.KinesisFirehose2EndpointBuilderFactory.KinesisFirehose2Builders,
+
org.apache.camel.builder.endpoint.dsl.KMS2EndpointBuilderFactory.KMS2Builders,
org.apache.camel.builder.endpoint.dsl.KubernetesConfigMapsEndpointBuilderFactory.KubernetesConfigMapsBuilders,
org.apache.camel.builder.endpoint.dsl.KubernetesCustomResourcesEndpointBuilderFactory.KubernetesCustomResourcesBuilders,
org.apache.camel.builder.endpoint.dsl.KubernetesDeploymentsEndpointBuilderFactory.KubernetesDeploymentsBuilders,
@@ -229,13 +229,11 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.LogEndpointBuilderFactory.LogBuilders,
org.apache.camel.builder.endpoint.dsl.LuceneEndpointBuilderFactory.LuceneBuilders,
org.apache.camel.builder.endpoint.dsl.LumberjackEndpointBuilderFactory.LumberjackBuilders,
-
org.apache.camel.builder.endpoint.dsl.MQ2EndpointBuilderFactory.MQ2Builders,
-
org.apache.camel.builder.endpoint.dsl.MSK2EndpointBuilderFactory.MSK2Builders,
org.apache.camel.builder.endpoint.dsl.MailEndpointBuilderFactory.MailBuilders,
org.apache.camel.builder.endpoint.dsl.MasterEndpointBuilderFactory.MasterBuilders,
org.apache.camel.builder.endpoint.dsl.MetricsEndpointBuilderFactory.MetricsBuilders,
-
org.apache.camel.builder.endpoint.dsl.MicroProfileMetricsEndpointBuilderFactory.MicroProfileMetricsBuilders,
org.apache.camel.builder.endpoint.dsl.MicrometerEndpointBuilderFactory.MicrometerBuilders,
+
org.apache.camel.builder.endpoint.dsl.MicroProfileMetricsEndpointBuilderFactory.MicroProfileMetricsBuilders,
org.apache.camel.builder.endpoint.dsl.MiloClientEndpointBuilderFactory.MiloClientBuilders,
org.apache.camel.builder.endpoint.dsl.MiloServerEndpointBuilderFactory.MiloServerBuilders,
org.apache.camel.builder.endpoint.dsl.MinaEndpointBuilderFactory.MinaBuilders,
@@ -243,6 +241,8 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.MllpEndpointBuilderFactory.MllpBuilders,
org.apache.camel.builder.endpoint.dsl.MockEndpointBuilderFactory.MockBuilders,
org.apache.camel.builder.endpoint.dsl.MongoDbEndpointBuilderFactory.MongoDbBuilders,
+
org.apache.camel.builder.endpoint.dsl.MQ2EndpointBuilderFactory.MQ2Builders,
+
org.apache.camel.builder.endpoint.dsl.MSK2EndpointBuilderFactory.MSK2Builders,
org.apache.camel.builder.endpoint.dsl.MsvEndpointBuilderFactory.MsvBuilders,
org.apache.camel.builder.endpoint.dsl.MustacheEndpointBuilderFactory.MustacheBuilders,
org.apache.camel.builder.endpoint.dsl.MvelEndpointBuilderFactory.MvelBuilders,
@@ -250,9 +250,9 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.MyBatisEndpointBuilderFactory.MyBatisBuilders,
org.apache.camel.builder.endpoint.dsl.NagiosEndpointBuilderFactory.NagiosBuilders,
org.apache.camel.builder.endpoint.dsl.NatsEndpointBuilderFactory.NatsBuilders,
-
org.apache.camel.builder.endpoint.dsl.NetWeaverEndpointBuilderFactory.NetWeaverBuilders,
org.apache.camel.builder.endpoint.dsl.NettyEndpointBuilderFactory.NettyBuilders,
org.apache.camel.builder.endpoint.dsl.NettyHttpEndpointBuilderFactory.NettyHttpBuilders,
+
org.apache.camel.builder.endpoint.dsl.NetWeaverEndpointBuilderFactory.NetWeaverBuilders,
org.apache.camel.builder.endpoint.dsl.NeutronEndpointBuilderFactory.NeutronBuilders,
org.apache.camel.builder.endpoint.dsl.NitriteEndpointBuilderFactory.NitriteBuilders,
org.apache.camel.builder.endpoint.dsl.NovaEndpointBuilderFactory.NovaBuilders,
@@ -281,13 +281,12 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.RedisEndpointBuilderFactory.RedisBuilders,
org.apache.camel.builder.endpoint.dsl.RefEndpointBuilderFactory.RefBuilders,
org.apache.camel.builder.endpoint.dsl.RestApiEndpointBuilderFactory.RestApiBuilders,
+
org.apache.camel.builder.endpoint.dsl.ResteasyEndpointBuilderFactory.ResteasyBuilders,
org.apache.camel.builder.endpoint.dsl.RestEndpointBuilderFactory.RestBuilders,
org.apache.camel.builder.endpoint.dsl.RestOpenApiEndpointBuilderFactory.RestOpenApiBuilders,
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.RssEndpointBuilderFactory.RssBuilders,
-
org.apache.camel.builder.endpoint.dsl.STS2EndpointBuilderFactory.STS2Builders,
org.apache.camel.builder.endpoint.dsl.SagaEndpointBuilderFactory.SagaBuilders,
org.apache.camel.builder.endpoint.dsl.SalesforceEndpointBuilderFactory.SalesforceBuilders,
org.apache.camel.builder.endpoint.dsl.SchedulerEndpointBuilderFactory.SchedulerBuilders,
@@ -330,6 +329,7 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.StompEndpointBuilderFactory.StompBuilders,
org.apache.camel.builder.endpoint.dsl.StreamEndpointBuilderFactory.StreamBuilders,
org.apache.camel.builder.endpoint.dsl.StringTemplateEndpointBuilderFactory.StringTemplateBuilders,
+
org.apache.camel.builder.endpoint.dsl.STS2EndpointBuilderFactory.STS2Builders,
org.apache.camel.builder.endpoint.dsl.StubEndpointBuilderFactory.StubBuilders,
org.apache.camel.builder.endpoint.dsl.SwiftEndpointBuilderFactory.SwiftBuilders,
org.apache.camel.builder.endpoint.dsl.TelegramEndpointBuilderFactory.TelegramBuilders,
@@ -359,10 +359,10 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.WsEndpointBuilderFactory.WsBuilders,
org.apache.camel.builder.endpoint.dsl.XChangeEndpointBuilderFactory.XChangeBuilders,
org.apache.camel.builder.endpoint.dsl.XJEndpointBuilderFactory.XJBuilders,
-
org.apache.camel.builder.endpoint.dsl.XQueryEndpointBuilderFactory.XQueryBuilders,
org.apache.camel.builder.endpoint.dsl.XmlSignerEndpointBuilderFactory.XmlSignerBuilders,
org.apache.camel.builder.endpoint.dsl.XmlVerifierEndpointBuilderFactory.XmlVerifierBuilders,
org.apache.camel.builder.endpoint.dsl.XmppEndpointBuilderFactory.XmppBuilders,
+
org.apache.camel.builder.endpoint.dsl.XQueryEndpointBuilderFactory.XQueryBuilders,
org.apache.camel.builder.endpoint.dsl.XsltEndpointBuilderFactory.XsltBuilders,
org.apache.camel.builder.endpoint.dsl.XsltSaxonEndpointBuilderFactory.XsltSaxonBuilders,
org.apache.camel.builder.endpoint.dsl.YammerEndpointBuilderFactory.YammerBuilders,
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index e819142..2120720 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -25,13 +25,11 @@ import javax.annotation.Generated;
@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
public interface EndpointBuilders
extends
- org.apache.camel.builder.endpoint.dsl.AMQPEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.AS2EndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.AWS2EC2EndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ActiveMQEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AhcEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.AMQPEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ArangoDbEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.AS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AsteriskEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.Athena2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory,
@@ -45,16 +43,16 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.AtomixSetEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AtomixValueEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AvroEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.AWS2EC2EndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BeanEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.BeanValidatorEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BeanstalkEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.BeanValidatorEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BlobEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BonitaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BoxEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BraintreeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.BrowseEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.CMEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.CMISEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CaffeineCacheEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CaffeineLoadCacheEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CassandraEndpointBuilderFactory,
@@ -63,20 +61,20 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.CinderEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ClassEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ClientEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.CMEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.CMISEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CoAPEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CometdEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ConsulEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ControlBusEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CosmosDbEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.CouchDbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CouchbaseEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.CouchDbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CronEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.Cw2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CxfEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CxfRsEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.DJLEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.DMSEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DataFormatEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DataLakeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DataSetEndpointBuilderFactory,
@@ -93,22 +91,24 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.DirectVmEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DisruptorEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DisruptorVmEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.DJLEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.DMSEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DnsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DockerEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DozerEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DrillEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DropboxEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ECS2EndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EhcacheEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.EKS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ElasticsearchEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ElsqlEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EtcdKeysEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EtcdStatsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EtcdWatchEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EventEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.EventHubsEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ExecEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.FacebookEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.FhirEndpointBuilderFactory,
@@ -144,7 +144,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GrpcEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GuavaEventBusEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.HBaseEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastAtomicnumberEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastInstanceEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastListEndpointBuilderFactory,
@@ -156,12 +155,11 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.HazelcastSedaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastSetEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastTopicEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.HBaseEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HdfsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HttpEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IAM2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IAMEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.IOTAEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.IPFSEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IgniteCacheEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IgniteComputeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IgniteEventsEndpointBuilderFactory,
@@ -173,36 +171,38 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.InfinispanEmbeddedEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.InfinispanRemoteEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.InfluxDbEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.IOTAEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.IPFSEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IrcEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.IronMQEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JBPMEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JCacheEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.JGroupsEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.JGroupsRaftEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.JMXEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.JSR356WebSocketEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JcloudsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JcrEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JdbcEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JettyHttpEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.JGroupsEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.JGroupsRaftEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JingEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JiraEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JmsEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.JMXEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JoltEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JooqEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JpaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JsltEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.JsonataEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JsonPatchEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.JsonValidatorEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.JsonataEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.JSR356WebSocketEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.Jt400EndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.KMS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KafkaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KameletEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KameletReifyEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KeystoneEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KinesisFirehose2EndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.KMS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KubernetesConfigMapsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KubernetesCustomResourcesEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.KubernetesDeploymentsEndpointBuilderFactory,
@@ -226,13 +226,11 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.LogEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.LuceneEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.LumberjackEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.MQ2EndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.MSK2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MailEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MasterEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MetricsEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.MicroProfileMetricsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MicrometerEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.MicroProfileMetricsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MiloClientEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MiloServerEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MinaEndpointBuilderFactory,
@@ -240,6 +238,8 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.MllpEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MockEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MongoDbEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.MQ2EndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.MSK2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MsvEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MustacheEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.MvelEndpointBuilderFactory,
@@ -247,9 +247,9 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.MyBatisEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NagiosEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NatsEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.NetWeaverEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NettyEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NettyHttpEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.NetWeaverEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NeutronEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NitriteEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.NovaEndpointBuilderFactory,
@@ -278,13 +278,12 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.RedisEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.RefEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.RestApiEndpointBuilderFactory,
+
org.apache.camel.builder.endpoint.dsl.ResteasyEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.RestEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.RestOpenApiEndpointBuilderFactory,
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.RssEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.STS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.SagaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.SalesforceEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.SchedulerEndpointBuilderFactory,
@@ -327,6 +326,7 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.StompEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.StreamEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.StringTemplateEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.STS2EndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.StubEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.SwiftEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.TelegramEndpointBuilderFactory,
@@ -356,10 +356,10 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.WsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XChangeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XJEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.XQueryEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XmlSignerEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XmlVerifierEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XmppEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.XQueryEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XsltEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.XsltSaxonEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.YammerEndpointBuilderFactory,
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
index 24252cf..0aa9420 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
@@ -78,6 +78,20 @@ public interface OBSEndpointBuilderFactory {
return this;
}
/**
+ * Name of object to perform operation with.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param objectName the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder objectName(String objectName) {
+ doSetProperty("objectName", objectName);
+ return this;
+ }
+ /**
* OBS service region. This is lower precedence than endpoint based
* configuration.
*
@@ -1162,6 +1176,20 @@ public interface OBSEndpointBuilderFactory {
return this;
}
/**
+ * Name of object to perform operation with.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param objectName the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointProducerBuilder objectName(String objectName) {
+ doSetProperty("objectName", objectName);
+ return this;
+ }
+ /**
* OBS service region. This is lower precedence than endpoint based
* configuration.
*
@@ -1458,6 +1486,20 @@ public interface OBSEndpointBuilderFactory {
return this;
}
/**
+ * Name of object to perform operation with.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param objectName the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointBuilder objectName(String objectName) {
+ doSetProperty("objectName", objectName);
+ return this;
+ }
+ /**
* OBS service region. This is lower precedence than endpoint based
* configuration.
*
