This is an automated email from the ASF dual-hosted git repository.
acosentino 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 0655c09 CAMEL-14871 - Regen docs, configurers and DSLs
0655c09 is described below
commit 0655c092f6ff53b80a60954b88805c758f0f482d
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jan 29 13:11:28 2021 +0100
CAMEL-14871 - Regen docs, configurers and DSLs
---
.../org/apache/camel/catalog/components/aws-s3.json | 2 ++
.../org/apache/camel/catalog/components/aws2-s3.json | 2 ++
.../org/apache/camel/catalog/docs/aws-s3-component.adoc | 6 ++++--
.../org/apache/camel/catalog/docs/aws2-s3-component.adoc | 6 ++++--
.../org/apache/camel/catalog/schemas/camel-spring.xsd | 1 -
.../camel/component/aws/s3/S3ComponentConfigurer.java | 6 ++++++
.../camel/component/aws/s3/S3EndpointUriFactory.java | 3 ++-
.../org/apache/camel/component/aws/s3/aws-s3.json | 3 ++-
.../camel-aws-s3/src/main/docs/aws-s3-component.adoc | 6 ++++--
.../component/aws2/s3/AWS2S3ComponentConfigurer.java | 6 ++++++
.../component/aws2/s3/AWS2S3EndpointConfigurer.java | 12 ++++++------
.../component/aws2/s3/AWS2S3EndpointUriFactory.java | 3 ++-
.../org/apache/camel/component/aws2/s3/aws2-s3.json | 3 ++-
.../camel-aws2-s3/src/main/docs/aws2-s3-component.adoc | 6 ++++--
.../component/dsl/Aws2S3ComponentBuilderFactory.java | 16 ++++++++++++++++
.../component/dsl/AwsS3ComponentBuilderFactory.java | 15 +++++++++++++++
.../endpoint/dsl/AWS2S3EndpointBuilderFactory.java | 14 ++++++++++++++
.../builder/endpoint/dsl/S3EndpointBuilderFactory.java | 14 ++++++++++++++
docs/components/modules/ROOT/pages/aws-s3-component.adoc | 6 ++++--
.../components/modules/ROOT/pages/aws2-s3-component.adoc | 6 ++++--
20 files changed, 113 insertions(+), 23 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-s3.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-s3.json
index d541d1e..1e97752 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-s3.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws-s3.json
@@ -39,6 +39,7 @@
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"deleteAfterRead": { "kind": "property", "displayName": "Delete After
Read", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchang [...]
"delimiter": { "kind": "property", "displayName": "Delimiter", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are intereste [...]
+ "doneFileName": { "kind": "property", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "property", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "property", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If it is true, the exchange body will be set
to a stream to the contents of the file. If false, the headers [...]
"prefix": { "kind": "property", "displayName": "Prefix", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "The prefix which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in." },
@@ -80,6 +81,7 @@
"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, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchan [...]
"delimiter": { "kind": "parameter", "displayName": "Delimiter", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interest [...]
+ "doneFileName": { "kind": "parameter", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "parameter", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "parameter", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If it is true, the exchange body will be set
to a stream to the contents of the file. If false, the header [...]
"maxConnections": { "kind": "parameter", "displayName": "Max Connections",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 60, "description": "Set the maxConnections parameter in the S3
client configuration" },
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-s3.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-s3.json
index bb5a4f4..1711605 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-s3.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-s3.json
@@ -45,6 +45,7 @@
"destinationBucket": { "kind": "property", "displayName": "Destination
Bucket", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket where an object
must be moved when moveAfterRead is set to true." },
"destinationBucketPrefix": { "kind": "property", "displayName":
"Destination Bucket Prefix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket prefix to use
when an object must be moved and moveAfterRead [...]
"destinationBucketSuffix": { "kind": "property", "displayName":
"Destination Bucket Suffix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket suffix to use
when an object must be moved and moveAfterRead [...]
+ "doneFileName": { "kind": "property", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "property", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "property", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S [...]
"includeFolders": { "kind": "property", "displayName": "Include Folders",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the folders\/directories will
be consumed. If it is false, they will be ignored, [...]
@@ -89,6 +90,7 @@
"destinationBucket": { "kind": "parameter", "displayName": "Destination
Bucket", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket where an object
must be moved when moveAfterRead is set to true." },
"destinationBucketPrefix": { "kind": "parameter", "displayName":
"Destination Bucket Prefix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket prefix to use
when an object must be moved and moveAfterRead [...]
"destinationBucketSuffix": { "kind": "parameter", "displayName":
"Destination Bucket Suffix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket suffix to use
when an object must be moved and moveAfterRead [...]
+ "doneFileName": { "kind": "parameter", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "parameter", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "parameter", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the [...]
"includeFolders": { "kind": "parameter", "displayName": "Include Folders",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the folders\/directories will
be consumed. If it is false, they will be ignored, [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-s3-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-s3-component.adoc
index d83eb2f4..553e63a 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-s3-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws-s3-component.adoc
@@ -47,7 +47,7 @@
from("aws-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&prefi
// component options: START
-The AWS S3 Storage Service component supports 39 options, which are listed
below.
+The AWS S3 Storage Service component supports 40 options, which are listed
below.
@@ -71,6 +71,7 @@ The AWS S3 Storage Service component supports 39 options,
which are listed below
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *deleteAfterRead* (consumer) | Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchange is committed. If a
rollback occurs, the object is not deleted. If this option is false, then the
same objects will be retrieve over and over again on the polls. Therefore you
need to use the Idempotent Consumer EIP in the route to filter out duplicates.
You can filter using the S3Constants#BUCKET_NAME and S3Constants#KEY headers,
or only the S3Constants#KEY [...]
| *delimiter* (consumer) | The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the exchange body will be set to a
stream to the contents of the file. If false, the headers will be set with the
S3 object metadata, but the body will be null. This option is strongly related
to autocloseBody option. In case of setting includeBody to true and
autocloseBody to false, it will be up to the caller to close the S3Object
stream. Setting autocloseBody to true, will close the S3Object stream
automatically. | true | boolean
| *prefix* (consumer) | The prefix which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
@@ -125,7 +126,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (57 parameters):
+=== Query Parameters (58 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -147,6 +148,7 @@ with the following path and query parameters:
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *deleteAfterRead* (consumer) | Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchange is committed. If a
rollback occurs, the object is not deleted. If this option is false, then the
same objects will be retrieve over and over again on the polls. Therefore you
need to use the Idempotent Consumer EIP in the route to filter out duplicates.
You can filter using the S3Constants#BUCKET_NAME and S3Constants#KEY headers,
or only the S3Constants#KEY [...]
| *delimiter* (consumer) | The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the exchange body will be set to a
stream to the contents of the file. If false, the headers will be set with the
S3 object metadata, but the body will be null. This option is strongly related
to autocloseBody option. In case of setting includeBody to true and
autocloseBody to false, it will be up to the caller to close the S3Object
stream. Setting autocloseBody to true, will close the S3Object stream
automatically. | true | boolean
| *maxConnections* (consumer) | Set the maxConnections parameter in the S3
client configuration | 60 | int
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
index ee7ccb9..dc800b1 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
@@ -47,7 +47,7 @@
from("aws2-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&pref
// component options: START
-The AWS 2 S3 Storage Service component supports 42 options, which are listed
below.
+The AWS 2 S3 Storage Service component supports 43 options, which are listed
below.
@@ -77,6 +77,7 @@ The AWS 2 S3 Storage Service component supports 42 options,
which are listed bel
| *destinationBucket* (consumer) | Define the destination bucket where an
object must be moved when moveAfterRead is set to true. | | String
| *destinationBucketPrefix* (consumer) | Define the destination bucket prefix
to use when an object must be moved and moveAfterRead is set to true. | |
String
| *destinationBucketSuffix* (consumer) | Define the destination bucket suffix
to use when an object must be moved and moveAfterRead is set to true. | |
String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S3Object stream will be
put raw into the body and the headers will be set with the S3 object metadata.
This option is strongly related to autocloseBody option. In case of setting
includeBody to true because the S3Object stream will be consumed then it will
also be closed in case of includeBody false then it will be up to the caller to
close the S3Object stream [...]
| *includeFolders* (consumer) | If it is true, the folders/directories will be
consumed. If it is false, they will be ignored, and Exchanges will not be
created for those | true | boolean
@@ -128,7 +129,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (60 parameters):
+=== Query Parameters (61 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -156,6 +157,7 @@ with the following path and query parameters:
| *destinationBucket* (consumer) | Define the destination bucket where an
object must be moved when moveAfterRead is set to true. | | String
| *destinationBucketPrefix* (consumer) | Define the destination bucket prefix
to use when an object must be moved and moveAfterRead is set to true. | |
String
| *destinationBucketSuffix* (consumer) | Define the destination bucket suffix
to use when an object must be moved and moveAfterRead is set to true. | |
String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S3Object stream will be
put raw into the body and the headers will be set with the S3 object metadata.
This option is strongly related to autocloseBody option. In case of setting
includeBody to true because the S3Object stream will be consumed then it will
also be closed in case of includeBody false then it will be up to the caller to
close the S3Object stream [...]
| *includeFolders* (consumer) | If it is true, the folders/directories will be
consumed. If it is false, they will be ignored, and Exchanges will not be
created for those | true | boolean
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
index 070e9a6..efd3087 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
@@ -14701,7 +14701,6 @@ Sets a reference to a thread pool to be used by the
error handler.
<xs:enumeration value="Verbose"/>
<xs:enumeration value="Default"/>
<xs:enumeration value="Brief"/>
- <xs:enumeration value="Oneline"/>
<xs:enumeration value="Off"/>
</xs:restriction>
</xs:simpleType>
diff --git
a/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3ComponentConfigurer.java
b/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3ComponentConfigurer.java
index a2bf37c..3601b42 100644
---
a/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3ComponentConfigurer.java
+++
b/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3ComponentConfigurer.java
@@ -54,6 +54,8 @@ public class S3ComponentConfigurer extends
PropertyConfigurerSupport implements
case "deleteafterwrite":
case "deleteAfterWrite":
getOrCreateConfiguration(target).setDeleteAfterWrite(property(camelContext,
boolean.class, value)); return true;
case "delimiter":
getOrCreateConfiguration(target).setDelimiter(property(camelContext,
java.lang.String.class, value)); return true;
+ case "donefilename":
+ case "doneFileName":
getOrCreateConfiguration(target).setDoneFileName(property(camelContext,
java.lang.String.class, value)); return true;
case "dualstackenabled":
case "dualstackEnabled":
getOrCreateConfiguration(target).setDualstackEnabled(property(camelContext,
boolean.class, value)); return true;
case "encryptionmaterials":
@@ -133,6 +135,8 @@ public class S3ComponentConfigurer extends
PropertyConfigurerSupport implements
case "deleteafterwrite":
case "deleteAfterWrite": return boolean.class;
case "delimiter": return java.lang.String.class;
+ case "donefilename":
+ case "doneFileName": return java.lang.String.class;
case "dualstackenabled":
case "dualstackEnabled": return boolean.class;
case "encryptionmaterials":
@@ -213,6 +217,8 @@ public class S3ComponentConfigurer extends
PropertyConfigurerSupport implements
case "deleteafterwrite":
case "deleteAfterWrite": return
getOrCreateConfiguration(target).isDeleteAfterWrite();
case "delimiter": return
getOrCreateConfiguration(target).getDelimiter();
+ case "donefilename":
+ case "doneFileName": return
getOrCreateConfiguration(target).getDoneFileName();
case "dualstackenabled":
case "dualstackEnabled": return
getOrCreateConfiguration(target).isDualstackEnabled();
case "encryptionmaterials":
diff --git
a/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3EndpointUriFactory.java
b/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3EndpointUriFactory.java
index 7406a4f..6e735c7 100644
---
a/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3EndpointUriFactory.java
+++
b/components/camel-aws-s3/src/generated/java/org/apache/camel/component/aws/s3/S3EndpointUriFactory.java
@@ -20,7 +20,7 @@ public class S3EndpointUriFactory extends
org.apache.camel.support.component.End
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(58);
+ Set<String> props = new HashSet<>(59);
props.add("useIAMCredentials");
props.add("fileName");
props.add("serverSideEncryption");
@@ -61,6 +61,7 @@ public class S3EndpointUriFactory extends
org.apache.camel.support.component.End
props.add("multiPartUpload");
props.add("storageClass");
props.add("useFixedDelay");
+ props.add("doneFileName");
props.add("runLoggingLevel");
props.add("backoffErrorThreshold");
props.add("policy");
diff --git
a/components/camel-aws-s3/src/generated/resources/org/apache/camel/component/aws/s3/aws-s3.json
b/components/camel-aws-s3/src/generated/resources/org/apache/camel/component/aws/s3/aws-s3.json
index 345b0ad..1e97752 100644
---
a/components/camel-aws-s3/src/generated/resources/org/apache/camel/component/aws/s3/aws-s3.json
+++
b/components/camel-aws-s3/src/generated/resources/org/apache/camel/component/aws/s3/aws-s3.json
@@ -39,7 +39,7 @@
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"deleteAfterRead": { "kind": "property", "displayName": "Delete After
Read", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchang [...]
"delimiter": { "kind": "property", "displayName": "Delimiter", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are intereste [...]
- "doneFileName": { "kind": "parameter", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"description": "Consumer: If provided, Camel will only consume files if a done
file exists. This option configures what file name to use. Either you can
specify a fixed name. Or you can use dynamic placeholders. The done file is
always expected in the same folder as [...]
+ "doneFileName": { "kind": "property", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "property", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "property", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If it is true, the exchange body will be set
to a stream to the contents of the file. If false, the headers [...]
"prefix": { "kind": "property", "displayName": "Prefix", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "The prefix which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in." },
@@ -81,6 +81,7 @@
"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, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchan [...]
"delimiter": { "kind": "parameter", "displayName": "Delimiter", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interest [...]
+ "doneFileName": { "kind": "parameter", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "parameter", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "parameter", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws.s3.S3Configuration", "configurationField":
"configuration", "description": "If it is true, the exchange body will be set
to a stream to the contents of the file. If false, the header [...]
"maxConnections": { "kind": "parameter", "displayName": "Max Connections",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 60, "description": "Set the maxConnections parameter in the S3
client configuration" },
diff --git a/components/camel-aws-s3/src/main/docs/aws-s3-component.adoc
b/components/camel-aws-s3/src/main/docs/aws-s3-component.adoc
index d83eb2f4..553e63a 100644
--- a/components/camel-aws-s3/src/main/docs/aws-s3-component.adoc
+++ b/components/camel-aws-s3/src/main/docs/aws-s3-component.adoc
@@ -47,7 +47,7 @@
from("aws-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&prefi
// component options: START
-The AWS S3 Storage Service component supports 39 options, which are listed
below.
+The AWS S3 Storage Service component supports 40 options, which are listed
below.
@@ -71,6 +71,7 @@ The AWS S3 Storage Service component supports 39 options,
which are listed below
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *deleteAfterRead* (consumer) | Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchange is committed. If a
rollback occurs, the object is not deleted. If this option is false, then the
same objects will be retrieve over and over again on the polls. Therefore you
need to use the Idempotent Consumer EIP in the route to filter out duplicates.
You can filter using the S3Constants#BUCKET_NAME and S3Constants#KEY headers,
or only the S3Constants#KEY [...]
| *delimiter* (consumer) | The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the exchange body will be set to a
stream to the contents of the file. If false, the headers will be set with the
S3 object metadata, but the body will be null. This option is strongly related
to autocloseBody option. In case of setting includeBody to true and
autocloseBody to false, it will be up to the caller to close the S3Object
stream. Setting autocloseBody to true, will close the S3Object stream
automatically. | true | boolean
| *prefix* (consumer) | The prefix which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
@@ -125,7 +126,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (57 parameters):
+=== Query Parameters (58 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -147,6 +148,7 @@ with the following path and query parameters:
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *deleteAfterRead* (consumer) | Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchange is committed. If a
rollback occurs, the object is not deleted. If this option is false, then the
same objects will be retrieve over and over again on the polls. Therefore you
need to use the Idempotent Consumer EIP in the route to filter out duplicates.
You can filter using the S3Constants#BUCKET_NAME and S3Constants#KEY headers,
or only the S3Constants#KEY [...]
| *delimiter* (consumer) | The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the exchange body will be set to a
stream to the contents of the file. If false, the headers will be set with the
S3 object metadata, but the body will be null. This option is strongly related
to autocloseBody option. In case of setting includeBody to true and
autocloseBody to false, it will be up to the caller to close the S3Object
stream. Setting autocloseBody to true, will close the S3Object stream
automatically. | true | boolean
| *maxConnections* (consumer) | Set the maxConnections parameter in the S3
client configuration | 60 | int
diff --git
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
index f00cc8c..77bb7d0 100644
---
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
+++
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
@@ -62,6 +62,8 @@ public class AWS2S3ComponentConfigurer extends
PropertyConfigurerSupport impleme
case "destinationBucketPrefix":
getOrCreateConfiguration(target).setDestinationBucketPrefix(property(camelContext,
java.lang.String.class, value)); return true;
case "destinationbucketsuffix":
case "destinationBucketSuffix":
getOrCreateConfiguration(target).setDestinationBucketSuffix(property(camelContext,
java.lang.String.class, value)); return true;
+ case "donefilename":
+ case "doneFileName":
getOrCreateConfiguration(target).setDoneFileName(property(camelContext,
java.lang.String.class, value)); return true;
case "filename":
case "fileName":
getOrCreateConfiguration(target).setFileName(property(camelContext,
java.lang.String.class, value)); return true;
case "includebody":
@@ -152,6 +154,8 @@ public class AWS2S3ComponentConfigurer extends
PropertyConfigurerSupport impleme
case "destinationBucketPrefix": return java.lang.String.class;
case "destinationbucketsuffix":
case "destinationBucketSuffix": return java.lang.String.class;
+ case "donefilename":
+ case "doneFileName": return java.lang.String.class;
case "filename":
case "fileName": return java.lang.String.class;
case "includebody":
@@ -238,6 +242,8 @@ public class AWS2S3ComponentConfigurer extends
PropertyConfigurerSupport impleme
case "destinationBucketPrefix": return
getOrCreateConfiguration(target).getDestinationBucketPrefix();
case "destinationbucketsuffix":
case "destinationBucketSuffix": return
getOrCreateConfiguration(target).getDestinationBucketSuffix();
+ case "donefilename":
+ case "doneFileName": return
getOrCreateConfiguration(target).getDoneFileName();
case "filename":
case "fileName": return getOrCreateConfiguration(target).getFileName();
case "includebody":
diff --git
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
index eff2b24..30d87c0 100644
---
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
+++
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
@@ -53,14 +53,14 @@ public class AWS2S3EndpointConfigurer extends
PropertyConfigurerSupport implemen
case "deleteafterwrite":
case "deleteAfterWrite":
target.getConfiguration().setDeleteAfterWrite(property(camelContext,
boolean.class, value)); return true;
case "delimiter":
target.getConfiguration().setDelimiter(property(camelContext,
java.lang.String.class, value)); return true;
- case "donefilename":
- case "doneFileName":
target.getConfiguration().setDoneFileName(property(camelContext,
java.lang.String.class, value)); return true;
case "destinationbucket":
case "destinationBucket":
target.getConfiguration().setDestinationBucket(property(camelContext,
java.lang.String.class, value)); return true;
case "destinationbucketprefix":
case "destinationBucketPrefix":
target.getConfiguration().setDestinationBucketPrefix(property(camelContext,
java.lang.String.class, value)); return true;
case "destinationbucketsuffix":
case "destinationBucketSuffix":
target.getConfiguration().setDestinationBucketSuffix(property(camelContext,
java.lang.String.class, value)); return true;
+ case "donefilename":
+ case "doneFileName":
target.getConfiguration().setDoneFileName(property(camelContext,
java.lang.String.class, value)); return true;
case "exceptionhandler":
case "exceptionHandler":
target.setExceptionHandler(property(camelContext,
org.apache.camel.spi.ExceptionHandler.class, value)); return true;
case "exchangepattern":
@@ -179,14 +179,14 @@ public class AWS2S3EndpointConfigurer extends
PropertyConfigurerSupport implemen
case "deleteafterwrite":
case "deleteAfterWrite": return boolean.class;
case "delimiter": return java.lang.String.class;
- case "donefilename":
- case "doneFileName": return java.lang.String.class;
case "destinationbucket":
case "destinationBucket": return java.lang.String.class;
case "destinationbucketprefix":
case "destinationBucketPrefix": return java.lang.String.class;
case "destinationbucketsuffix":
case "destinationBucketSuffix": return java.lang.String.class;
+ case "donefilename":
+ case "doneFileName": return java.lang.String.class;
case "exceptionhandler":
case "exceptionHandler": return
org.apache.camel.spi.ExceptionHandler.class;
case "exchangepattern":
@@ -301,14 +301,14 @@ public class AWS2S3EndpointConfigurer extends
PropertyConfigurerSupport implemen
case "deleteafterwrite":
case "deleteAfterWrite": return
target.getConfiguration().isDeleteAfterWrite();
case "delimiter": return target.getConfiguration().getDelimiter();
- case "donefilename":
- case "doneFileName": return
target.getConfiguration().getDoneFileName();
case "destinationbucket":
case "destinationBucket": return
target.getConfiguration().getDestinationBucket();
case "destinationbucketprefix":
case "destinationBucketPrefix": return
target.getConfiguration().getDestinationBucketPrefix();
case "destinationbucketsuffix":
case "destinationBucketSuffix": return
target.getConfiguration().getDestinationBucketSuffix();
+ case "donefilename":
+ case "doneFileName": return
target.getConfiguration().getDoneFileName();
case "exceptionhandler":
case "exceptionHandler": return target.getExceptionHandler();
case "exchangepattern":
diff --git
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointUriFactory.java
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointUriFactory.java
index b45fe9d..f88438a 100644
---
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointUriFactory.java
+++
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointUriFactory.java
@@ -20,7 +20,7 @@ public class AWS2S3EndpointUriFactory extends
org.apache.camel.support.component
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(61);
+ Set<String> props = new HashSet<>(62);
props.add("customerAlgorithm");
props.add("fileName");
props.add("useCustomerKey");
@@ -62,6 +62,7 @@ public class AWS2S3EndpointUriFactory extends
org.apache.camel.support.component
props.add("multiPartUpload");
props.add("storageClass");
props.add("useFixedDelay");
+ props.add("doneFileName");
props.add("runLoggingLevel");
props.add("backoffErrorThreshold");
props.add("policy");
diff --git
a/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
b/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
index 1464f9a..1711605 100644
---
a/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
+++
b/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
@@ -42,10 +42,10 @@
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"deleteAfterRead": { "kind": "property", "displayName": "Delete After
Read", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Delete objects from S3 after they have been
retrieved. The delete is only performed if the Ex [...]
"delimiter": { "kind": "property", "displayName": "Delimiter", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are inte [...]
- "doneFileName": { "kind": "parameter", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"description": "Consumer: If provided, Camel will only consume files if a done
file exists. This option configures what file name to use. Either you can
specify a fixed name. Or you can use dynamic placeholders. The done file is
always expected in the same folder as [...]
"destinationBucket": { "kind": "property", "displayName": "Destination
Bucket", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket where an object
must be moved when moveAfterRead is set to true." },
"destinationBucketPrefix": { "kind": "property", "displayName":
"Destination Bucket Prefix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket prefix to use
when an object must be moved and moveAfterRead [...]
"destinationBucketSuffix": { "kind": "property", "displayName":
"Destination Bucket Suffix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket suffix to use
when an object must be moved and moveAfterRead [...]
+ "doneFileName": { "kind": "property", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "property", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "property", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S [...]
"includeFolders": { "kind": "property", "displayName": "Include Folders",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the folders\/directories will
be consumed. If it is false, they will be ignored, [...]
@@ -90,6 +90,7 @@
"destinationBucket": { "kind": "parameter", "displayName": "Destination
Bucket", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket where an object
must be moved when moveAfterRead is set to true." },
"destinationBucketPrefix": { "kind": "parameter", "displayName":
"Destination Bucket Prefix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket prefix to use
when an object must be moved and moveAfterRead [...]
"destinationBucketSuffix": { "kind": "parameter", "displayName":
"Destination Bucket Suffix", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Define the destination bucket suffix to use
when an object must be moved and moveAfterRead [...]
+ "doneFileName": { "kind": "parameter", "displayName": "Done File Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If provided, Camel will only consume files if
a done file exists." },
"fileName": { "kind": "parameter", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "To get the object from the bucket with the
given file name" },
"includeBody": { "kind": "parameter", "displayName": "Include Body",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the [...]
"includeFolders": { "kind": "parameter", "displayName": "Include Folders",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If it is true, the folders\/directories will
be consumed. If it is false, they will be ignored, [...]
diff --git a/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
b/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
index ee7ccb9..dc800b1 100644
--- a/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
+++ b/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
@@ -47,7 +47,7 @@
from("aws2-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&pref
// component options: START
-The AWS 2 S3 Storage Service component supports 42 options, which are listed
below.
+The AWS 2 S3 Storage Service component supports 43 options, which are listed
below.
@@ -77,6 +77,7 @@ The AWS 2 S3 Storage Service component supports 42 options,
which are listed bel
| *destinationBucket* (consumer) | Define the destination bucket where an
object must be moved when moveAfterRead is set to true. | | String
| *destinationBucketPrefix* (consumer) | Define the destination bucket prefix
to use when an object must be moved and moveAfterRead is set to true. | |
String
| *destinationBucketSuffix* (consumer) | Define the destination bucket suffix
to use when an object must be moved and moveAfterRead is set to true. | |
String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S3Object stream will be
put raw into the body and the headers will be set with the S3 object metadata.
This option is strongly related to autocloseBody option. In case of setting
includeBody to true because the S3Object stream will be consumed then it will
also be closed in case of includeBody false then it will be up to the caller to
close the S3Object stream [...]
| *includeFolders* (consumer) | If it is true, the folders/directories will be
consumed. If it is false, they will be ignored, and Exchanges will not be
created for those | true | boolean
@@ -128,7 +129,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (60 parameters):
+=== Query Parameters (61 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -156,6 +157,7 @@ with the following path and query parameters:
| *destinationBucket* (consumer) | Define the destination bucket where an
object must be moved when moveAfterRead is set to true. | | String
| *destinationBucketPrefix* (consumer) | Define the destination bucket prefix
to use when an object must be moved and moveAfterRead is set to true. | |
String
| *destinationBucketSuffix* (consumer) | Define the destination bucket suffix
to use when an object must be moved and moveAfterRead is set to true. | |
String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S3Object stream will be
put raw into the body and the headers will be set with the S3 object metadata.
This option is strongly related to autocloseBody option. In case of setting
includeBody to true because the S3Object stream will be consumed then it will
also be closed in case of includeBody false then it will be up to the caller to
close the S3Object stream [...]
| *includeFolders* (consumer) | If it is true, the folders/directories will be
consumed. If it is false, they will be ignored, and Exchanges will not be
created for those | true | boolean
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
index 015c326..6f57d9e 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
@@ -432,6 +432,21 @@ public interface Aws2S3ComponentBuilderFactory {
return this;
}
/**
+ * If provided, Camel will only consume files if a done file exists.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param doneFileName the value to set
+ * @return the dsl builder
+ */
+ default Aws2S3ComponentBuilder doneFileName(
+ java.lang.String doneFileName) {
+ doSetProperty("doneFileName", doneFileName);
+ return this;
+ }
+ /**
* To get the object from the bucket with the given file name.
*
* The option is a: <code>java.lang.String</code> type.
@@ -798,6 +813,7 @@ public interface Aws2S3ComponentBuilderFactory {
case "destinationBucket":
getOrCreateConfiguration((AWS2S3Component)
component).setDestinationBucket((java.lang.String) value); return true;
case "destinationBucketPrefix":
getOrCreateConfiguration((AWS2S3Component)
component).setDestinationBucketPrefix((java.lang.String) value); return true;
case "destinationBucketSuffix":
getOrCreateConfiguration((AWS2S3Component)
component).setDestinationBucketSuffix((java.lang.String) value); return true;
+ case "doneFileName": getOrCreateConfiguration((AWS2S3Component)
component).setDoneFileName((java.lang.String) value); return true;
case "fileName": getOrCreateConfiguration((AWS2S3Component)
component).setFileName((java.lang.String) value); return true;
case "includeBody": getOrCreateConfiguration((AWS2S3Component)
component).setIncludeBody((boolean) value); return true;
case "includeFolders": getOrCreateConfiguration((AWS2S3Component)
component).setIncludeFolders((boolean) value); return true;
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsS3ComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsS3ComponentBuilderFactory.java
index 9ff3456..e7af1d6 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsS3ComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsS3ComponentBuilderFactory.java
@@ -330,6 +330,20 @@ public interface AwsS3ComponentBuilderFactory {
return this;
}
/**
+ * If provided, Camel will only consume files if a done file exists.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param doneFileName the value to set
+ * @return the dsl builder
+ */
+ default AwsS3ComponentBuilder doneFileName(java.lang.String
doneFileName) {
+ doSetProperty("doneFileName", doneFileName);
+ return this;
+ }
+ /**
* To get the object from the bucket with the given file name.
*
* The option is a: <code>java.lang.String</code> type.
@@ -730,6 +744,7 @@ public interface AwsS3ComponentBuilderFactory {
case "bridgeErrorHandler": ((S3Component)
component).setBridgeErrorHandler((boolean) value); return true;
case "deleteAfterRead": getOrCreateConfiguration((S3Component)
component).setDeleteAfterRead((boolean) value); return true;
case "delimiter": getOrCreateConfiguration((S3Component)
component).setDelimiter((java.lang.String) value); return true;
+ case "doneFileName": getOrCreateConfiguration((S3Component)
component).setDoneFileName((java.lang.String) value); return true;
case "fileName": getOrCreateConfiguration((S3Component)
component).setFileName((java.lang.String) value); return true;
case "includeBody": getOrCreateConfiguration((S3Component)
component).setIncludeBody((boolean) value); return true;
case "prefix": getOrCreateConfiguration((S3Component)
component).setPrefix((java.lang.String) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
index fd7d110..1a50ac9 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
@@ -572,6 +572,20 @@ public interface AWS2S3EndpointBuilderFactory {
return this;
}
/**
+ * If provided, Camel will only consume files if a done file exists.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param doneFileName the value to set
+ * @return the dsl builder
+ */
+ default AWS2S3EndpointConsumerBuilder doneFileName(String
doneFileName) {
+ doSetProperty("doneFileName", doneFileName);
+ return this;
+ }
+ /**
* To get the object from the bucket with the given file name.
*
* The option is a: <code>java.lang.String</code> type.
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
index 7e0be47..c9af821 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
@@ -458,6 +458,20 @@ public interface S3EndpointBuilderFactory {
return this;
}
/**
+ * If provided, Camel will only consume files if a done file exists.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param doneFileName the value to set
+ * @return the dsl builder
+ */
+ default S3EndpointConsumerBuilder doneFileName(String doneFileName) {
+ doSetProperty("doneFileName", doneFileName);
+ return this;
+ }
+ /**
* To get the object from the bucket with the given file name.
*
* The option is a: <code>java.lang.String</code> type.
diff --git a/docs/components/modules/ROOT/pages/aws-s3-component.adoc
b/docs/components/modules/ROOT/pages/aws-s3-component.adoc
index 1763e89..062dbfc 100644
--- a/docs/components/modules/ROOT/pages/aws-s3-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws-s3-component.adoc
@@ -49,7 +49,7 @@
from("aws-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&prefi
// component options: START
-The AWS S3 Storage Service component supports 39 options, which are listed
below.
+The AWS S3 Storage Service component supports 40 options, which are listed
below.
@@ -73,6 +73,7 @@ The AWS S3 Storage Service component supports 39 options,
which are listed below
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *deleteAfterRead* (consumer) | Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchange is committed. If a
rollback occurs, the object is not deleted. If this option is false, then the
same objects will be retrieve over and over again on the polls. Therefore you
need to use the Idempotent Consumer EIP in the route to filter out duplicates.
You can filter using the S3Constants#BUCKET_NAME and S3Constants#KEY headers,
or only the S3Constants#KEY [...]
| *delimiter* (consumer) | The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the exchange body will be set to a
stream to the contents of the file. If false, the headers will be set with the
S3 object metadata, but the body will be null. This option is strongly related
to autocloseBody option. In case of setting includeBody to true and
autocloseBody to false, it will be up to the caller to close the S3Object
stream. Setting autocloseBody to true, will close the S3Object stream
automatically. | true | boolean
| *prefix* (consumer) | The prefix which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
@@ -127,7 +128,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (57 parameters):
+=== Query Parameters (58 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -149,6 +150,7 @@ with the following path and query parameters:
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *deleteAfterRead* (consumer) | Delete objects from S3 after they have been
retrieved. The delete is only performed if the Exchange is committed. If a
rollback occurs, the object is not deleted. If this option is false, then the
same objects will be retrieve over and over again on the polls. Therefore you
need to use the Idempotent Consumer EIP in the route to filter out duplicates.
You can filter using the S3Constants#BUCKET_NAME and S3Constants#KEY headers,
or only the S3Constants#KEY [...]
| *delimiter* (consumer) | The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume objects we
are interested in. | | String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the exchange body will be set to a
stream to the contents of the file. If false, the headers will be set with the
S3 object metadata, but the body will be null. This option is strongly related
to autocloseBody option. In case of setting includeBody to true and
autocloseBody to false, it will be up to the caller to close the S3Object
stream. Setting autocloseBody to true, will close the S3Object stream
automatically. | true | boolean
| *maxConnections* (consumer) | Set the maxConnections parameter in the S3
client configuration | 60 | int
diff --git a/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
b/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
index 47f8a4b..a820c7e 100644
--- a/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
@@ -49,7 +49,7 @@
from("aws2-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&pref
// component options: START
-The AWS 2 S3 Storage Service component supports 42 options, which are listed
below.
+The AWS 2 S3 Storage Service component supports 43 options, which are listed
below.
@@ -79,6 +79,7 @@ The AWS 2 S3 Storage Service component supports 42 options,
which are listed bel
| *destinationBucket* (consumer) | Define the destination bucket where an
object must be moved when moveAfterRead is set to true. | | String
| *destinationBucketPrefix* (consumer) | Define the destination bucket prefix
to use when an object must be moved and moveAfterRead is set to true. | |
String
| *destinationBucketSuffix* (consumer) | Define the destination bucket suffix
to use when an object must be moved and moveAfterRead is set to true. | |
String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S3Object stream will be
put raw into the body and the headers will be set with the S3 object metadata.
This option is strongly related to autocloseBody option. In case of setting
includeBody to true because the S3Object stream will be consumed then it will
also be closed in case of includeBody false then it will be up to the caller to
close the S3Object stream [...]
| *includeFolders* (consumer) | If it is true, the folders/directories will be
consumed. If it is false, they will be ignored, and Exchanges will not be
created for those | true | boolean
@@ -130,7 +131,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (60 parameters):
+=== Query Parameters (61 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -158,6 +159,7 @@ with the following path and query parameters:
| *destinationBucket* (consumer) | Define the destination bucket where an
object must be moved when moveAfterRead is set to true. | | String
| *destinationBucketPrefix* (consumer) | Define the destination bucket prefix
to use when an object must be moved and moveAfterRead is set to true. | |
String
| *destinationBucketSuffix* (consumer) | Define the destination bucket suffix
to use when an object must be moved and moveAfterRead is set to true. | |
String
+| *doneFileName* (consumer) | If provided, Camel will only consume files if a
done file exists. | | String
| *fileName* (consumer) | To get the object from the bucket with the given
file name | | String
| *includeBody* (consumer) | If it is true, the S3Object exchange will be
consumed and put into the body and closed. If false the S3Object stream will be
put raw into the body and the headers will be set with the S3 object metadata.
This option is strongly related to autocloseBody option. In case of setting
includeBody to true because the S3Object stream will be consumed then it will
also be closed in case of includeBody false then it will be up to the caller to
close the S3Object stream [...]
| *includeFolders* (consumer) | If it is true, the folders/directories will be
consumed. If it is false, they will be ignored, and Exchanges will not be
created for those | true | boolean
