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 2020/08/10 14:52:16 UTC
[camel] branch master updated: CAMEL-13934: Polished and regen
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new d75a66b CAMEL-13934: Polished and regen
d75a66b is described below
commit d75a66b0734fd2e64fc0b3ef09cb29d0d753b6fc
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Aug 10 16:51:26 2020 +0200
CAMEL-13934: Polished and regen
---
.../org/apache/camel/catalog/components/minio.json | 11 ++--
.../apache/camel/catalog/docs/minio-component.adoc | 7 +-
components/camel-minio/pom.xml | 74 +---------------------
.../component/minio/MinioComponentConfigurer.java | 15 +++--
.../component/minio/MinioEndpointConfigurer.java | 8 +--
.../org/apache/camel/component/minio/minio.json | 11 ++--
.../camel-minio/src/main/docs/minio-component.adoc | 7 +-
.../camel/component/minio/MinioConfiguration.java | 38 ++++++++++-
.../camel/component/minio/MinioEndpoint.java | 62 +++---------------
.../dsl/MinioComponentBuilderFactory.java | 43 +++++++++----
.../src/generated/resources/metadata.json | 2 +-
.../builder/endpoint/StaticEndpointBuilders.java | 8 +--
.../endpoint/dsl/MinioEndpointBuilderFactory.java | 8 +--
.../modules/ROOT/pages/minio-component.adoc | 7 +-
14 files changed, 125 insertions(+), 176 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/minio.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/minio.json
index f976da7..c0920b3 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/minio.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/minio.json
@@ -14,7 +14,7 @@
"version": "3.5.0-SNAPSHOT",
"scheme": "minio",
"extendsScheme": "",
- "syntax": "minio:\/\/bucketName",
+ "syntax": "minio:bucketName",
"async": false,
"consumerOnly": false,
"producerOnly": false,
@@ -22,7 +22,6 @@
},
"componentProperties": {
"autoCreateBucket": { "kind": "property", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket if bucket name not exist." },
- "bucketName": { "kind": "property", "displayName": "Bucket Name", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Name of the bucket. The bucket will be created if it doesn't already exists." },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.minio.MinioConfiguration", "deprecated": false, "secret": false, "description": "The component configuration" },
"customHttpClient": { "kind": "property", "displayName": "Custom Http Client", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "okhttp3.OkHttpClient", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set custom HTTP client for authenticated access." },
"endpoint": { "kind": "property", "displayName": "Endpoint", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Endpoint can be an URL, domain name, IPv4 address or IPv6 address." },
@@ -47,6 +46,8 @@
"includeVersions": { "kind": "property", "displayName": "Include Versions", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "The flag which is used in the ListObjectsRequest to get objects with versioning." },
"length": { "kind": "property", "displayName": "Length", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Number of bytes of object data from offset." },
"matchETag": { "kind": "property", "displayName": "Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set match ETag parameter for get object(s)." },
+ "maxConnections": { "kind": "property", "displayName": "Max Connections", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "60", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set the maxConnections parameter in the minio client configuration" },
+ "maxMessagesPerPoll": { "kind": "property", "displayName": "Max Messages Per Poll", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a [...]
"modifiedSince": { "kind": "property", "displayName": "Modified Since", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.time.ZonedDateTime", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set modified since parameter for get object(s)." },
"moveAfterRead": { "kind": "property", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the destin [...]
"notMatchETag": { "kind": "property", "displayName": "Not Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set not match ETag parameter for get object(s)." },
@@ -69,7 +70,7 @@
"secretKey": { "kind": "property", "displayName": "Secret Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": true, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Amazon AWS Access Key Id or Minio Secret Key. If not set camel will connect to service for anonymous access." }
},
"properties": {
- "bucketName": { "kind": "path", "displayName": "Bucket Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "description": "Bucket name" },
+ "bucketName": { "kind": "path", "displayName": "Bucket Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Bucket name" },
"autoCreateBucket": { "kind": "parameter", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket if bucket name not exist." },
"customHttpClient": { "kind": "parameter", "displayName": "Custom Http Client", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "okhttp3.OkHttpClient", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set custom HTTP client for authenticated access." },
"endpoint": { "kind": "parameter", "displayName": "Endpoint", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Endpoint can be an URL, domain name, IPv4 address or IPv6 address." },
@@ -94,8 +95,8 @@
"includeVersions": { "kind": "parameter", "displayName": "Include Versions", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "The flag which is used in the ListObjectsRequest to get objects with versioning." },
"length": { "kind": "parameter", "displayName": "Length", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Number of bytes of object data from offset." },
"matchETag": { "kind": "parameter", "displayName": "Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set match ETag parameter for get object(s)." },
- "maxConnections": { "kind": "parameter", "displayName": "Max Connections", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "60", "description": "Set the maxConnections parameter in the minio client configuration" },
- "maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages Per Poll", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "10", "description": "Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited." },
+ "maxConnections": { "kind": "parameter", "displayName": "Max Connections", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "60", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set the maxConnections parameter in the minio client configuration" },
+ "maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages Per Poll", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a [...]
"modifiedSince": { "kind": "parameter", "displayName": "Modified Since", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.time.ZonedDateTime", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set modified since parameter for get object(s)." },
"moveAfterRead": { "kind": "parameter", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the desti [...]
"notMatchETag": { "kind": "parameter", "displayName": "Not Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set not match ETag parameter for get object(s)." },
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/minio-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/minio-component.adoc
index 354accf..0e44679 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/minio-component.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/minio-component.adoc
@@ -41,7 +41,7 @@ from("minio://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&prefix
== URI Options
// component options: START
-The Minio Storage Service component supports 46 options, which are listed below.
+The Minio Storage Service component supports 47 options, which are listed below.
@@ -49,7 +49,6 @@ The Minio Storage Service component supports 46 options, which are listed below.
|===
| Name | Description | Default | Type
| *autoCreateBucket* (common) | Setting the autocreation of the bucket if bucket name not exist. | true | boolean
-| *bucketName* (common) | Name of the bucket. The bucket will be created if it doesn't already exists. | false | String
| *configuration* (common) | The component configuration | | MinioConfiguration
| *customHttpClient* (common) | Set custom HTTP client for authenticated access. | | OkHttpClient
| *endpoint* (common) | Endpoint can be an URL, domain name, IPv4 address or IPv6 address. | | String
@@ -74,6 +73,8 @@ The Minio Storage Service component supports 46 options, which are listed below.
| *includeVersions* (consumer) | The flag which is used in the ListObjectsRequest to get objects with versioning. | false | boolean
| *length* (consumer) | Number of bytes of object data from offset. | | long
| *matchETag* (consumer) | Set match ETag parameter for get object(s). | | String
+| *maxConnections* (consumer) | Set the maxConnections parameter in the minio client configuration | 60 | int
+| *maxMessagesPerPoll* (consumer) | Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited. | 10 | int
| *modifiedSince* (consumer) | Set modified since parameter for get object(s). | | ZonedDateTime
| *moveAfterRead* (consumer) | Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the destinationBucket option must be set. The copy bucket operation is only performed if the Exchange is committed. If a rollback occurs, the object is not moved. | false | boolean
| *notMatchETag* (consumer) | Set not match ETag parameter for get object(s). | | String
@@ -101,7 +102,7 @@ The Minio Storage Service component supports 46 options, which are listed below.
The Minio Storage Service endpoint is configured using URI syntax:
----
-minio://bucketName
+minio:bucketName
----
with the following path and query parameters:
diff --git a/components/camel-minio/pom.xml b/components/camel-minio/pom.xml
index 0b06826..9328d7d 100644
--- a/components/camel-minio/pom.xml
+++ b/components/camel-minio/pom.xml
@@ -31,23 +31,15 @@
<packaging>jar</packaging>
<name>Camel :: MinIO</name>
- <description>A Camel MinIO cloud storage server Component</description>
-
- <properties>
- <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
- <camel.osgi.export.pkg>org.apache.camel.component.minio.*</camel.osgi.export.pkg>
- <camel.osgi.export.service>
- org.apache.camel.spi.ComponentResolver;component=minio
- </camel.osgi.export.service>
- </properties>
+ <description>Store and retrieve objects from Minio Storage Service</description>
<dependencies>
- <!-- camel -->
+
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-support</artifactId>
</dependency>
+
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
@@ -84,64 +76,4 @@
</dependency>
</dependencies>
- <build>
- <defaultGoal>install</defaultGoal>
-
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-compiler-plugin</artifactId>
- <configuration>
- <source>1.8</source>
- <target>1.8</target>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-resources-plugin</artifactId>
- <configuration>
- <encoding>UTF-8</encoding>
- </configuration>
- </plugin>
-
- <!-- generate camel meta-data -->
- <plugin>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-component-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>generate</id>
- <goals>
- <goal>generate</goal>
- </goals>
- <phase>process-classes</phase>
- </execution>
- </executions>
- </plugin>
- <plugin>
- <groupId>org.codehaus.mojo</groupId>
- <artifactId>build-helper-maven-plugin</artifactId>
- <executions>
- <execution>
- <phase>initialize</phase>
- <goals>
- <goal>add-source</goal>
- <goal>add-resource</goal>
- </goals>
- <configuration>
- <sources>
- <source>src/generated/java</source>
- </sources>
- <resources>
- <resource>
- <directory>src/generated/resources</directory>
- </resource>
- </resources>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
-
</project>
diff --git a/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioComponentConfigurer.java b/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioComponentConfigurer.java
index 15288fe..31dd6a5 100644
--- a/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioComponentConfigurer.java
+++ b/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioComponentConfigurer.java
@@ -36,8 +36,6 @@ public class MinioComponentConfigurer extends PropertyConfigurerSupport implemen
case "basicPropertyBinding": target.setBasicPropertyBinding(property(camelContext, boolean.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
- case "bucketname":
- case "bucketName": getOrCreateConfiguration(target).setBucketName(property(camelContext, java.lang.String.class, value)); return true;
case "bypassgovernancemode":
case "bypassGovernanceMode": getOrCreateConfiguration(target).setBypassGovernanceMode(property(camelContext, boolean.class, value)); return true;
case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.minio.MinioConfiguration.class, value)); return true;
@@ -68,6 +66,10 @@ public class MinioComponentConfigurer extends PropertyConfigurerSupport implemen
case "length": getOrCreateConfiguration(target).setLength(property(camelContext, long.class, value)); return true;
case "matchetag":
case "matchETag": getOrCreateConfiguration(target).setMatchETag(property(camelContext, java.lang.String.class, value)); return true;
+ case "maxconnections":
+ case "maxConnections": getOrCreateConfiguration(target).setMaxConnections(property(camelContext, int.class, value)); return true;
+ case "maxmessagesperpoll":
+ case "maxMessagesPerPoll": getOrCreateConfiguration(target).setMaxMessagesPerPoll(property(camelContext, int.class, value)); return true;
case "minioclient":
case "minioClient": getOrCreateConfiguration(target).setMinioClient(property(camelContext, io.minio.MinioClient.class, value)); return true;
case "modifiedsince":
@@ -119,7 +121,6 @@ public class MinioComponentConfigurer extends PropertyConfigurerSupport implemen
answer.put("autoCreateBucket", boolean.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("bridgeErrorHandler", boolean.class);
- answer.put("bucketName", java.lang.String.class);
answer.put("bypassGovernanceMode", boolean.class);
answer.put("configuration", org.apache.camel.component.minio.MinioConfiguration.class);
answer.put("customHttpClient", okhttp3.OkHttpClient.class);
@@ -137,6 +138,8 @@ public class MinioComponentConfigurer extends PropertyConfigurerSupport implemen
answer.put("lazyStartProducer", boolean.class);
answer.put("length", long.class);
answer.put("matchETag", java.lang.String.class);
+ answer.put("maxConnections", int.class);
+ answer.put("maxMessagesPerPoll", int.class);
answer.put("minioClient", io.minio.MinioClient.class);
answer.put("modifiedSince", java.time.ZonedDateTime.class);
answer.put("moveAfterRead", boolean.class);
@@ -177,8 +180,6 @@ public class MinioComponentConfigurer extends PropertyConfigurerSupport implemen
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "bucketname":
- case "bucketName": return getOrCreateConfiguration(target).getBucketName();
case "bypassgovernancemode":
case "bypassGovernanceMode": return getOrCreateConfiguration(target).isBypassGovernanceMode();
case "configuration": return target.getConfiguration();
@@ -209,6 +210,10 @@ public class MinioComponentConfigurer extends PropertyConfigurerSupport implemen
case "length": return getOrCreateConfiguration(target).getLength();
case "matchetag":
case "matchETag": return getOrCreateConfiguration(target).getMatchETag();
+ case "maxconnections":
+ case "maxConnections": return getOrCreateConfiguration(target).getMaxConnections();
+ case "maxmessagesperpoll":
+ case "maxMessagesPerPoll": return getOrCreateConfiguration(target).getMaxMessagesPerPoll();
case "minioclient":
case "minioClient": return getOrCreateConfiguration(target).getMinioClient();
case "modifiedsince":
diff --git a/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioEndpointConfigurer.java b/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioEndpointConfigurer.java
index d76cb8c..1c0d1a1 100644
--- a/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioEndpointConfigurer.java
+++ b/components/camel-minio/src/generated/java/org/apache/camel/component/minio/MinioEndpointConfigurer.java
@@ -73,9 +73,9 @@ public class MinioEndpointConfigurer extends PropertyConfigurerSupport implement
case "matchetag":
case "matchETag": target.getConfiguration().setMatchETag(property(camelContext, java.lang.String.class, value)); return true;
case "maxconnections":
- case "maxConnections": target.setMaxConnections(property(camelContext, int.class, value)); return true;
+ case "maxConnections": target.getConfiguration().setMaxConnections(property(camelContext, int.class, value)); return true;
case "maxmessagesperpoll":
- case "maxMessagesPerPoll": target.setMaxMessagesPerPoll(property(camelContext, int.class, value)); return true;
+ case "maxMessagesPerPoll": target.getConfiguration().setMaxMessagesPerPoll(property(camelContext, int.class, value)); return true;
case "minioclient":
case "minioClient": target.getConfiguration().setMinioClient(property(camelContext, io.minio.MinioClient.class, value)); return true;
case "modifiedsince":
@@ -268,9 +268,9 @@ public class MinioEndpointConfigurer extends PropertyConfigurerSupport implement
case "matchetag":
case "matchETag": return target.getConfiguration().getMatchETag();
case "maxconnections":
- case "maxConnections": return target.getMaxConnections();
+ case "maxConnections": return target.getConfiguration().getMaxConnections();
case "maxmessagesperpoll":
- case "maxMessagesPerPoll": return target.getMaxMessagesPerPoll();
+ case "maxMessagesPerPoll": return target.getConfiguration().getMaxMessagesPerPoll();
case "minioclient":
case "minioClient": return target.getConfiguration().getMinioClient();
case "modifiedsince":
diff --git a/components/camel-minio/src/generated/resources/org/apache/camel/component/minio/minio.json b/components/camel-minio/src/generated/resources/org/apache/camel/component/minio/minio.json
index f976da7..c0920b3 100644
--- a/components/camel-minio/src/generated/resources/org/apache/camel/component/minio/minio.json
+++ b/components/camel-minio/src/generated/resources/org/apache/camel/component/minio/minio.json
@@ -14,7 +14,7 @@
"version": "3.5.0-SNAPSHOT",
"scheme": "minio",
"extendsScheme": "",
- "syntax": "minio:\/\/bucketName",
+ "syntax": "minio:bucketName",
"async": false,
"consumerOnly": false,
"producerOnly": false,
@@ -22,7 +22,6 @@
},
"componentProperties": {
"autoCreateBucket": { "kind": "property", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket if bucket name not exist." },
- "bucketName": { "kind": "property", "displayName": "Bucket Name", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Name of the bucket. The bucket will be created if it doesn't already exists." },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.minio.MinioConfiguration", "deprecated": false, "secret": false, "description": "The component configuration" },
"customHttpClient": { "kind": "property", "displayName": "Custom Http Client", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "okhttp3.OkHttpClient", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set custom HTTP client for authenticated access." },
"endpoint": { "kind": "property", "displayName": "Endpoint", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Endpoint can be an URL, domain name, IPv4 address or IPv6 address." },
@@ -47,6 +46,8 @@
"includeVersions": { "kind": "property", "displayName": "Include Versions", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "The flag which is used in the ListObjectsRequest to get objects with versioning." },
"length": { "kind": "property", "displayName": "Length", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Number of bytes of object data from offset." },
"matchETag": { "kind": "property", "displayName": "Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set match ETag parameter for get object(s)." },
+ "maxConnections": { "kind": "property", "displayName": "Max Connections", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "60", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set the maxConnections parameter in the minio client configuration" },
+ "maxMessagesPerPoll": { "kind": "property", "displayName": "Max Messages Per Poll", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a [...]
"modifiedSince": { "kind": "property", "displayName": "Modified Since", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.time.ZonedDateTime", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set modified since parameter for get object(s)." },
"moveAfterRead": { "kind": "property", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the destin [...]
"notMatchETag": { "kind": "property", "displayName": "Not Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set not match ETag parameter for get object(s)." },
@@ -69,7 +70,7 @@
"secretKey": { "kind": "property", "displayName": "Secret Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": true, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Amazon AWS Access Key Id or Minio Secret Key. If not set camel will connect to service for anonymous access." }
},
"properties": {
- "bucketName": { "kind": "path", "displayName": "Bucket Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "description": "Bucket name" },
+ "bucketName": { "kind": "path", "displayName": "Bucket Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Bucket name" },
"autoCreateBucket": { "kind": "parameter", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket if bucket name not exist." },
"customHttpClient": { "kind": "parameter", "displayName": "Custom Http Client", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "okhttp3.OkHttpClient", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set custom HTTP client for authenticated access." },
"endpoint": { "kind": "parameter", "displayName": "Endpoint", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Endpoint can be an URL, domain name, IPv4 address or IPv6 address." },
@@ -94,8 +95,8 @@
"includeVersions": { "kind": "parameter", "displayName": "Include Versions", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "The flag which is used in the ListObjectsRequest to get objects with versioning." },
"length": { "kind": "parameter", "displayName": "Length", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Number of bytes of object data from offset." },
"matchETag": { "kind": "parameter", "displayName": "Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set match ETag parameter for get object(s)." },
- "maxConnections": { "kind": "parameter", "displayName": "Max Connections", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "60", "description": "Set the maxConnections parameter in the minio client configuration" },
- "maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages Per Poll", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "10", "description": "Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited." },
+ "maxConnections": { "kind": "parameter", "displayName": "Max Connections", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "60", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set the maxConnections parameter in the minio client configuration" },
+ "maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages Per Poll", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "secret": false, "defaultValue": "10", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a [...]
"modifiedSince": { "kind": "parameter", "displayName": "Modified Since", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.time.ZonedDateTime", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set modified since parameter for get object(s)." },
"moveAfterRead": { "kind": "parameter", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the desti [...]
"notMatchETag": { "kind": "parameter", "displayName": "Not Match ETag", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.minio.MinioConfiguration", "configurationField": "configuration", "description": "Set not match ETag parameter for get object(s)." },
diff --git a/components/camel-minio/src/main/docs/minio-component.adoc b/components/camel-minio/src/main/docs/minio-component.adoc
index 354accf..0e44679 100644
--- a/components/camel-minio/src/main/docs/minio-component.adoc
+++ b/components/camel-minio/src/main/docs/minio-component.adoc
@@ -41,7 +41,7 @@ from("minio://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&prefix
== URI Options
// component options: START
-The Minio Storage Service component supports 46 options, which are listed below.
+The Minio Storage Service component supports 47 options, which are listed below.
@@ -49,7 +49,6 @@ The Minio Storage Service component supports 46 options, which are listed below.
|===
| Name | Description | Default | Type
| *autoCreateBucket* (common) | Setting the autocreation of the bucket if bucket name not exist. | true | boolean
-| *bucketName* (common) | Name of the bucket. The bucket will be created if it doesn't already exists. | false | String
| *configuration* (common) | The component configuration | | MinioConfiguration
| *customHttpClient* (common) | Set custom HTTP client for authenticated access. | | OkHttpClient
| *endpoint* (common) | Endpoint can be an URL, domain name, IPv4 address or IPv6 address. | | String
@@ -74,6 +73,8 @@ The Minio Storage Service component supports 46 options, which are listed below.
| *includeVersions* (consumer) | The flag which is used in the ListObjectsRequest to get objects with versioning. | false | boolean
| *length* (consumer) | Number of bytes of object data from offset. | | long
| *matchETag* (consumer) | Set match ETag parameter for get object(s). | | String
+| *maxConnections* (consumer) | Set the maxConnections parameter in the minio client configuration | 60 | int
+| *maxMessagesPerPoll* (consumer) | Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited. | 10 | int
| *modifiedSince* (consumer) | Set modified since parameter for get object(s). | | ZonedDateTime
| *moveAfterRead* (consumer) | Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the destinationBucket option must be set. The copy bucket operation is only performed if the Exchange is committed. If a rollback occurs, the object is not moved. | false | boolean
| *notMatchETag* (consumer) | Set not match ETag parameter for get object(s). | | String
@@ -101,7 +102,7 @@ The Minio Storage Service component supports 46 options, which are listed below.
The Minio Storage Service endpoint is configured using URI syntax:
----
-minio://bucketName
+minio:bucketName
----
with the following path and query parameters:
diff --git a/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioConfiguration.java b/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioConfiguration.java
index ee18fe1..4e37e98 100644
--- a/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioConfiguration.java
+++ b/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioConfiguration.java
@@ -23,12 +23,18 @@ import io.minio.ServerSideEncryption;
import io.minio.ServerSideEncryptionCustomerKey;
import okhttp3.OkHttpClient;
import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
+import org.apache.camel.spi.UriPath;
@UriParams
public class MinioConfiguration implements Cloneable {
+ @UriPath(description = "Bucket name")
+ @Metadata(required = true)
+ private String bucketName;
+
@UriParam(label = "common")
private String endpoint;
@UriParam(label = "common")
@@ -44,9 +50,7 @@ public class MinioConfiguration implements Cloneable {
private String accessKey;
@UriParam(label = "security", secret = true)
private String secretKey;
- @UriParam(label = "common", defaultValue = "false")
- private String bucketName;
@UriParam(label = "common", defaultValue = "true")
private boolean autoCreateBucket = true;
@UriParam(label = "common", defaultValue = "false")
@@ -60,6 +64,10 @@ public class MinioConfiguration implements Cloneable {
@UriParam(label = "common")
private MinioClient minioClient;
+ @UriParam(label = "consumer", defaultValue = "10")
+ private int maxMessagesPerPoll = 10;
+ @UriParam(label = "consumer", defaultValue = "60")
+ private int maxConnections = 50 + maxMessagesPerPoll;
@UriParam(label = "consumer")
private String objectName;
@UriParam(label = "consumer")
@@ -277,6 +285,32 @@ public class MinioConfiguration implements Cloneable {
this.minioClient = minioClient;
}
+ public int getMaxMessagesPerPoll() {
+ return maxMessagesPerPoll;
+ }
+
+ /**
+ * Gets the maximum number of messages as a limit to poll at each polling.
+ * <p/>
+ * Gets the maximum number of messages as a limit to poll at each polling.
+ * The default value is 10. Use 0 or a negative number to set it as
+ * unlimited.
+ */
+ public void setMaxMessagesPerPoll(int maxMessagesPerPoll) {
+ this.maxMessagesPerPoll = maxMessagesPerPoll;
+ }
+
+ public int getMaxConnections() {
+ return maxConnections;
+ }
+
+ /**
+ * Set the maxConnections parameter in the minio client configuration
+ */
+ public void setMaxConnections(int maxConnections) {
+ this.maxConnections = maxConnections;
+ }
+
public String getObjectName() {
return objectName;
}
diff --git a/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioEndpoint.java b/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioEndpoint.java
index e61a785..c03dbc1 100644
--- a/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioEndpoint.java
+++ b/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioEndpoint.java
@@ -40,10 +40,8 @@ import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.component.minio.client.MinioClientFactory;
-import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriPath;
import org.apache.camel.support.ScheduledPollEndpoint;
import org.apache.camel.support.SynchronizationAdapter;
import org.apache.camel.util.IOHelper;
@@ -55,24 +53,16 @@ import static org.apache.camel.util.ObjectHelper.isNotEmpty;
/**
* Store and retrieve objects from Minio Storage Service using Minio SDK.
*/
-@UriEndpoint(firstVersion = "3.5.0", scheme = "minio", title = "Minio Storage Service", syntax = "minio://bucketName",
+@UriEndpoint(firstVersion = "3.5.0", scheme = "minio", title = "Minio Storage Service", syntax = "minio:bucketName",
category = {Category.CLOUD, Category.FILE})
-
public class MinioEndpoint extends ScheduledPollEndpoint {
private static final Logger LOG = LoggerFactory.getLogger(MinioEndpoint.class);
private MinioClient minioClient;
- @UriPath(description = "Bucket name")
- @Metadata(required = true)
- private String bucketName;
@UriParam
private MinioConfiguration configuration;
- @UriParam(label = "consumer", defaultValue = "10")
- private int maxMessagesPerPoll = 10;
- @UriParam(label = "consumer", defaultValue = "60")
- private int maxConnections = 50 + maxMessagesPerPoll;
public MinioEndpoint(String uri, Component component, MinioConfiguration configuration) {
super(uri, component);
@@ -83,7 +73,7 @@ public class MinioEndpoint extends ScheduledPollEndpoint {
public Consumer createConsumer(Processor processor) throws Exception {
MinioConsumer minioConsumer = new MinioConsumer(this, processor);
configureConsumer(minioConsumer);
- minioConsumer.setMaxMessagesPerPoll(maxMessagesPerPoll);
+ minioConsumer.setMaxMessagesPerPoll(configuration.getMaxMessagesPerPoll());
return minioConsumer;
}
@@ -150,20 +140,14 @@ public class MinioEndpoint extends ScheduledPollEndpoint {
getObjectStat(objectName, message);
if (getConfiguration().isIncludeBody()) {
- try {
- message.setBody(readInputStream(minioObject));
- if (getConfiguration().isAutoCloseBody()) {
- exchange.adapt(ExtendedExchange.class).addOnCompletion(new SynchronizationAdapter() {
- @Override
- public void onDone(Exchange exchange) {
- IOHelper.close(minioObject);
- }
- });
- }
-
- } catch (IOException e) {
- // TODO Auto-generated catch block
- LOG.warn("Error setting message body");
+ message.setBody(readInputStream(minioObject));
+ if (getConfiguration().isAutoCloseBody()) {
+ exchange.adapt(ExtendedExchange.class).addOnCompletion(new SynchronizationAdapter() {
+ @Override
+ public void onDone(Exchange exchange) {
+ IOHelper.close(minioObject);
+ }
+ });
}
} else {
message.setBody(null);
@@ -189,32 +173,6 @@ public class MinioEndpoint extends ScheduledPollEndpoint {
this.minioClient = minioClient;
}
- public int getMaxMessagesPerPoll() {
- return maxMessagesPerPoll;
- }
-
- /**
- * Gets the maximum number of messages as a limit to poll at each polling.
- * <p/>
- * Gets the maximum number of messages as a limit to poll at each polling.
- * The default value is 10. Use 0 or a negative number to set it as
- * unlimited.
- */
- public void setMaxMessagesPerPoll(int maxMessagesPerPoll) {
- this.maxMessagesPerPoll = maxMessagesPerPoll;
- }
-
- public int getMaxConnections() {
- return maxConnections;
- }
-
- /**
- * Set the maxConnections parameter in the minio client configuration
- */
- public void setMaxConnections(int maxConnections) {
- this.maxConnections = maxConnections;
- }
-
private String readInputStream(InputStream minioObject) throws IOException {
StringBuilder textBuilder = new StringBuilder();
try (Reader reader = new BufferedReader(new InputStreamReader(minioObject, StandardCharsets.UTF_8))) {
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/MinioComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/MinioComponentBuilderFactory.java
index 37478c1..511ae36 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/MinioComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/MinioComponentBuilderFactory.java
@@ -59,19 +59,6 @@ public interface MinioComponentBuilderFactory {
return this;
}
/**
- * Name of the bucket. The bucket will be created if it doesn't already
- * exists.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: false
- * Group: common
- */
- default MinioComponentBuilder bucketName(java.lang.String bucketName) {
- doSetProperty("bucketName", bucketName);
- return this;
- }
- /**
* The component configuration.
*
* The option is a:
@@ -392,6 +379,33 @@ public interface MinioComponentBuilderFactory {
return this;
}
/**
+ * Set the maxConnections parameter in the minio client configuration.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 60
+ * Group: consumer
+ */
+ default MinioComponentBuilder maxConnections(int maxConnections) {
+ doSetProperty("maxConnections", maxConnections);
+ return this;
+ }
+ /**
+ * Gets the maximum number of messages as a limit to poll at each
+ * polling. Gets the maximum number of messages as a limit to poll at
+ * each polling. The default value is 10. Use 0 or a negative number to
+ * set it as unlimited.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 10
+ * Group: consumer
+ */
+ default MinioComponentBuilder maxMessagesPerPoll(int maxMessagesPerPoll) {
+ doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
+ return this;
+ }
+ /**
* Set modified since parameter for get object(s).
*
* The option is a: <code>java.time.ZonedDateTime</code> type.
@@ -664,7 +678,6 @@ public interface MinioComponentBuilderFactory {
Object value) {
switch (name) {
case "autoCreateBucket": getOrCreateConfiguration((MinioComponent) component).setAutoCreateBucket((boolean) value); return true;
- case "bucketName": getOrCreateConfiguration((MinioComponent) component).setBucketName((java.lang.String) value); return true;
case "configuration": ((MinioComponent) component).setConfiguration((org.apache.camel.component.minio.MinioConfiguration) value); return true;
case "customHttpClient": getOrCreateConfiguration((MinioComponent) component).setCustomHttpClient((okhttp3.OkHttpClient) value); return true;
case "endpoint": getOrCreateConfiguration((MinioComponent) component).setEndpoint((java.lang.String) value); return true;
@@ -689,6 +702,8 @@ public interface MinioComponentBuilderFactory {
case "includeVersions": getOrCreateConfiguration((MinioComponent) component).setIncludeVersions((boolean) value); return true;
case "length": getOrCreateConfiguration((MinioComponent) component).setLength((long) value); return true;
case "matchETag": getOrCreateConfiguration((MinioComponent) component).setMatchETag((java.lang.String) value); return true;
+ case "maxConnections": getOrCreateConfiguration((MinioComponent) component).setMaxConnections((int) value); return true;
+ case "maxMessagesPerPoll": getOrCreateConfiguration((MinioComponent) component).setMaxMessagesPerPoll((int) value); return true;
case "modifiedSince": getOrCreateConfiguration((MinioComponent) component).setModifiedSince((java.time.ZonedDateTime) value); return true;
case "moveAfterRead": getOrCreateConfiguration((MinioComponent) component).setMoveAfterRead((boolean) value); return true;
case "notMatchETag": getOrCreateConfiguration((MinioComponent) component).setNotMatchETag((java.lang.String) value); return true;
diff --git a/core/camel-componentdsl/src/generated/resources/metadata.json b/core/camel-componentdsl/src/generated/resources/metadata.json
index 96a946f..53ff371 100644
--- a/core/camel-componentdsl/src/generated/resources/metadata.json
+++ b/core/camel-componentdsl/src/generated/resources/metadata.json
@@ -4870,7 +4870,7 @@
"version": "3.5.0-SNAPSHOT",
"scheme": "minio",
"extendsScheme": "",
- "syntax": "minio:\/\/bucketName",
+ "syntax": "minio:bucketName",
"async": false,
"consumerOnly": false,
"producerOnly": false,
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index 369fb96..edf4ba9 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -10080,12 +10080,12 @@ public class StaticEndpointBuilders {
* Since: 3.5
* Maven coordinates: org.apache.camel:camel-minio
*
- * Syntax: <code>minio://bucketName</code>
+ * Syntax: <code>minio:bucketName</code>
*
* Path parameter: bucketName (required)
* Bucket name
*
- * @param path //bucketName
+ * @param path bucketName
*/
public static org.apache.camel.builder.endpoint.dsl.MinioEndpointBuilderFactory.MinioEndpointBuilder minio(
String path) {
@@ -10099,14 +10099,14 @@ public class StaticEndpointBuilders {
* Since: 3.5
* Maven coordinates: org.apache.camel:camel-minio
*
- * Syntax: <code>minio://bucketName</code>
+ * Syntax: <code>minio:bucketName</code>
*
* Path parameter: bucketName (required)
* Bucket name
*
* @param componentName to use a custom component name for the endpoint
* instead of the default name
- * @param path //bucketName
+ * @param path bucketName
*/
public static org.apache.camel.builder.endpoint.dsl.MinioEndpointBuilderFactory.MinioEndpointBuilder minio(
String componentName,
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MinioEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MinioEndpointBuilderFactory.java
index 929aa39..40f9568 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MinioEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MinioEndpointBuilderFactory.java
@@ -2286,12 +2286,12 @@ public interface MinioEndpointBuilderFactory {
* Since: 3.5
* Maven coordinates: org.apache.camel:camel-minio
*
- * Syntax: <code>minio://bucketName</code>
+ * Syntax: <code>minio:bucketName</code>
*
* Path parameter: bucketName (required)
* Bucket name
*
- * @param path //bucketName
+ * @param path bucketName
*/
default MinioEndpointBuilder minio(String path) {
return MinioEndpointBuilderFactory.endpointBuilder("minio", path);
@@ -2305,14 +2305,14 @@ public interface MinioEndpointBuilderFactory {
* Since: 3.5
* Maven coordinates: org.apache.camel:camel-minio
*
- * Syntax: <code>minio://bucketName</code>
+ * Syntax: <code>minio:bucketName</code>
*
* Path parameter: bucketName (required)
* Bucket name
*
* @param componentName to use a custom component name for the endpoint
* instead of the default name
- * @param path //bucketName
+ * @param path bucketName
*/
default MinioEndpointBuilder minio(String componentName, String path) {
return MinioEndpointBuilderFactory.endpointBuilder(componentName, path);
diff --git a/docs/components/modules/ROOT/pages/minio-component.adoc b/docs/components/modules/ROOT/pages/minio-component.adoc
index 7c02bb3..970682c 100644
--- a/docs/components/modules/ROOT/pages/minio-component.adoc
+++ b/docs/components/modules/ROOT/pages/minio-component.adoc
@@ -43,7 +43,7 @@ from("minio://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&prefix
== URI Options
// component options: START
-The Minio Storage Service component supports 46 options, which are listed below.
+The Minio Storage Service component supports 47 options, which are listed below.
@@ -51,7 +51,6 @@ The Minio Storage Service component supports 46 options, which are listed below.
|===
| Name | Description | Default | Type
| *autoCreateBucket* (common) | Setting the autocreation of the bucket if bucket name not exist. | true | boolean
-| *bucketName* (common) | Name of the bucket. The bucket will be created if it doesn't already exists. | false | String
| *configuration* (common) | The component configuration | | MinioConfiguration
| *customHttpClient* (common) | Set custom HTTP client for authenticated access. | | OkHttpClient
| *endpoint* (common) | Endpoint can be an URL, domain name, IPv4 address or IPv6 address. | | String
@@ -76,6 +75,8 @@ The Minio Storage Service component supports 46 options, which are listed below.
| *includeVersions* (consumer) | The flag which is used in the ListObjectsRequest to get objects with versioning. | false | boolean
| *length* (consumer) | Number of bytes of object data from offset. | | long
| *matchETag* (consumer) | Set match ETag parameter for get object(s). | | String
+| *maxConnections* (consumer) | Set the maxConnections parameter in the minio client configuration | 60 | int
+| *maxMessagesPerPoll* (consumer) | Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited. | 10 | int
| *modifiedSince* (consumer) | Set modified since parameter for get object(s). | | ZonedDateTime
| *moveAfterRead* (consumer) | Move objects from bucket to a different bucket after they have been retrieved. To accomplish the operation the destinationBucket option must be set. The copy bucket operation is only performed if the Exchange is committed. If a rollback occurs, the object is not moved. | false | boolean
| *notMatchETag* (consumer) | Set not match ETag parameter for get object(s). | | String
@@ -103,7 +104,7 @@ The Minio Storage Service component supports 46 options, which are listed below.
The Minio Storage Service endpoint is configured using URI syntax:
----
-minio://bucketName
+minio:bucketName
----
with the following path and query parameters: