This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 4a8018167a4 Regen
4a8018167a4 is described below
commit 4a8018167a44d567f1526758b8b1292ed7ac821a
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Mar 20 10:17:27 2023 +0100
Regen
---
.../catalog/components/azure-storage-datalake.json | 26 +-
.../apache/camel/catalog/main/sensitive-keys.json | 3 +
.../datalake/DataLakeComponentConfigurer.java | 18 +
.../datalake/DataLakeEndpointConfigurer.java | 18 +
.../datalake/DataLakeEndpointUriFactory.java | 13 +-
.../storage/datalake/azure-storage-datalake.json | 26 +-
.../java/org/apache/camel/util/SensitiveUtils.java | 8 +-
...zureStorageDatalakeComponentBuilderFactory.java | 150 +++--
.../dsl/DataLakeEndpointBuilderFactory.java | 683 ++++++++++++++-------
9 files changed, 664 insertions(+), 281 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
index 46c4caa1984..14d0f33f702 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
@@ -22,10 +22,7 @@
"lenientProperties": false
},
"componentProperties": {
- "accountKey": { "kind": "property", "displayName": "Account Key", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
"clientId": { "kind": "property", "displayName": "Client Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client id for azure
account" },
- "clientSecret": { "kind": "property", "displayName": "Client Secret",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
- "clientSecretCredential": { "kind": "property", "displayName": "Client
Secret Credential", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.azure.identity.ClientSecretCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
"close": { "kind": "property", "displayName": "Close", "group": "common",
"label": "", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Whether or not a file
changed event raised indicates completion (true) or modification (false)" },
"closeStreamAfterRead": { "kind": "property", "displayName": "Close Stream
After Read", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "check for closing stream
after read" },
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description":
"configuration object for datalake" },
@@ -54,7 +51,13 @@
"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 [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.datalake.DataLakeOperationsDefinition",
"enum": [ "listFileSystem", "listFiles" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "listFileSystem", "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField" [...]
- "autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ "autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ "accountKey": { "kind": "property", "displayName": "Account Key", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
+ "clientSecret": { "kind": "property", "displayName": "Client Secret",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
+ "clientSecretCredential": { "kind": "property", "displayName": "Client
Secret Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.identity.ClientSecretCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
+ "sasCredential": { "kind": "property", "displayName": "Sas Credential",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "com.azure.core.credential.AzureSasCredential", "deprecated":
false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token credential" },
+ "sasSignature": { "kind": "property", "displayName": "Sas Signature",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token signature" },
+ "useDefaultIdentity": { "kind": "property", "displayName": "Use Default
Identity", "group": "security", "label": "security", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Use default identity" }
},
"headers": {
"CamelAzureStorageDataLakeListFileSystemsOptions": { "kind": "header",
"displayName": "", "group": "from user", "label": "from user", "required":
false, "javaType": "ListFileSystemsOptions", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description":
"Defines options available to configure the behavior of a call to
listFileSystemsSegment on a DataLakeServiceAsyncClient object. Null may be
passed.", "constantName": "org.apache.camel.component.azure. [...]
@@ -117,15 +120,14 @@
"CamelAzureStorageDataLakeProgressConsumer": { "kind": "header",
"displayName": "", "group": "from user", "label": "from user", "required":
false, "javaType": "Consumer<FileQueryProgress>", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description":
"Sets progress consumer for file query", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#PROGRESS_CONSUMER"
},
"CamelAzureStorageDataLakeQueryOptions": { "kind": "header",
"displayName": "", "group": "from user", "label": "from user", "required":
false, "javaType": "FileQueryOptions", "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "description": "Optional parameters
for File Query.", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#QUERY_OPTIONS"
},
"CamelAzureStorageDataLakePermission": { "kind": "header", "displayName":
"", "group": "from user", "label": "from user", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets the permission for file.",
"constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#PERMISSION"
},
- "CamelAzureStorageDataLakeUmask": { "kind": "header", "displayName": "",
"group": "from user", "label": "from user", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets the umask for file.", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#UMASK" }
+ "CamelAzureStorageDataLakeUmask": { "kind": "header", "displayName": "",
"group": "from user", "label": "from user", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets the umask for file.", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#UMASK" },
+ "CamelAzureStorageDataLakeFileClient": { "kind": "header", "displayName":
"", "group": "from user", "label": "from user", "required": false, "javaType":
"DataLakeFileClient", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Sets the file client to use",
"constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#FILE_CLIENT"
},
+ "CamelAzureStorageDataLakeFlush": { "kind": "header", "displayName": "",
"group": "from user", "label": "from user", "required": false, "javaType":
"Boolean", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets whether to flush on append",
"constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#FLUSH" }
},
"properties": {
"accountName": { "kind": "path", "displayName": "Account Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "name of the azure
account" },
"fileSystemName": { "kind": "path", "displayName": "File System Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "name of filesystem to be
used" },
- "accountKey": { "kind": "parameter", "displayName": "Account Key",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
"clientId": { "kind": "parameter", "displayName": "Client Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client id for azure
account" },
- "clientSecret": { "kind": "parameter", "displayName": "Client Secret",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
- "clientSecretCredential": { "kind": "parameter", "displayName": "Client
Secret Credential", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.azure.identity.ClientSecretCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
"close": { "kind": "parameter", "displayName": "Close", "group": "common",
"label": "", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Whether or not a file
changed event raised indicates completion (true) or modification (false)" },
"closeStreamAfterRead": { "kind": "parameter", "displayName": "Close
Stream After Read", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "check for closing stream
after read" },
"dataCount": { "kind": "parameter", "displayName": "Data Count", "group":
"common", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Long", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "count number of bytes to
download" },
@@ -171,6 +173,12 @@
"schedulerProperties": { "kind": "parameter", "displayName": "Scheduler
Properties", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.util.Map<java.lang.String,
java.lang.Object>", "prefix": "scheduler.", "multiValue": true, "deprecated":
false, "autowired": false, "secret": false, "description": "To configure
additional properties when using a custom scheduler or any of the Quartz,
Spring based scheduler." },
"startScheduler": { "kind": "parameter", "displayName": "Start Scheduler",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether the scheduler
should be auto started." },
"timeUnit": { "kind": "parameter", "displayName": "Time Unit", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"object", "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS",
"MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"MILLISECONDS", "description": "Time unit for initialDelay and delay options."
},
- "useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Controls if fixed delay
or fixed rate is used. See ScheduledExecutorService in JDK for details." }
+ "useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Controls if fixed delay
or fixed rate is used. See ScheduledExecutorService in JDK for details." },
+ "accountKey": { "kind": "parameter", "displayName": "Account Key",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
+ "clientSecret": { "kind": "parameter", "displayName": "Client Secret",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
+ "clientSecretCredential": { "kind": "parameter", "displayName": "Client
Secret Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.identity.ClientSecretCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
+ "sasCredential": { "kind": "parameter", "displayName": "Sas Credential",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "com.azure.core.credential.AzureSasCredential", "deprecated":
false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token credential" },
+ "sasSignature": { "kind": "parameter", "displayName": "Sas Signature",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token signature" },
+ "useDefaultIdentity": { "kind": "parameter", "displayName": "Use Default
Identity", "group": "security", "label": "security", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Use default identity" }
}
}
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/sensitive-keys.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/sensitive-keys.json
index a2783d1b9ed..d29c3718b60 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/sensitive-keys.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/main/sensitive-keys.json
@@ -18,6 +18,7 @@
"cipherkey",
"clientid",
"clientsecret",
+ "clientsecretcredential",
"connectionstring",
"consumerkey",
"consumersecret",
@@ -48,7 +49,9 @@
"publishkey",
"queueownerawsaccountid",
"refreshtoken",
+ "sascredential",
"sasljaasconfig",
+ "sassignature",
"secretkey",
"securerandom",
"sharedaccesskey",
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeComponentConfigurer.java
b/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeComponentConfigurer.java
index 498cba2b055..4f54b187418 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeComponentConfigurer.java
+++
b/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeComponentConfigurer.java
@@ -73,6 +73,10 @@ public class DataLakeComponentConfigurer extends
PropertyConfigurerSupport imple
case "regex":
getOrCreateConfiguration(target).setRegex(property(camelContext,
java.lang.String.class, value)); return true;
case "retainuncommiteddata":
case "retainUncommitedData":
getOrCreateConfiguration(target).setRetainUncommitedData(property(camelContext,
java.lang.Boolean.class, value)); return true;
+ case "sascredential":
+ case "sasCredential":
getOrCreateConfiguration(target).setSasCredential(property(camelContext,
com.azure.core.credential.AzureSasCredential.class, value)); return true;
+ case "sassignature":
+ case "sasSignature":
getOrCreateConfiguration(target).setSasSignature(property(camelContext,
java.lang.String.class, value)); return true;
case "serviceclient":
case "serviceClient":
getOrCreateConfiguration(target).setServiceClient(property(camelContext,
com.azure.storage.file.datalake.DataLakeServiceClient.class, value)); return
true;
case "sharedkeycredential":
@@ -81,6 +85,8 @@ public class DataLakeComponentConfigurer extends
PropertyConfigurerSupport imple
case "tenantId":
getOrCreateConfiguration(target).setTenantId(property(camelContext,
java.lang.String.class, value)); return true;
case "timeout":
getOrCreateConfiguration(target).setTimeout(property(camelContext,
java.time.Duration.class, value)); return true;
case "umask":
getOrCreateConfiguration(target).setUmask(property(camelContext,
java.lang.String.class, value)); return true;
+ case "usedefaultidentity":
+ case "useDefaultIdentity":
getOrCreateConfiguration(target).setUseDefaultIdentity(property(camelContext,
java.lang.Boolean.class, value)); return true;
case "userprincipalnamereturned":
case "userPrincipalNameReturned":
getOrCreateConfiguration(target).setUserPrincipalNameReturned(property(camelContext,
java.lang.Boolean.class, value)); return true;
default: return false;
@@ -140,6 +146,10 @@ public class DataLakeComponentConfigurer extends
PropertyConfigurerSupport imple
case "regex": return java.lang.String.class;
case "retainuncommiteddata":
case "retainUncommitedData": return java.lang.Boolean.class;
+ case "sascredential":
+ case "sasCredential": return
com.azure.core.credential.AzureSasCredential.class;
+ case "sassignature":
+ case "sasSignature": return java.lang.String.class;
case "serviceclient":
case "serviceClient": return
com.azure.storage.file.datalake.DataLakeServiceClient.class;
case "sharedkeycredential":
@@ -148,6 +158,8 @@ public class DataLakeComponentConfigurer extends
PropertyConfigurerSupport imple
case "tenantId": return java.lang.String.class;
case "timeout": return java.time.Duration.class;
case "umask": return java.lang.String.class;
+ case "usedefaultidentity":
+ case "useDefaultIdentity": return java.lang.Boolean.class;
case "userprincipalnamereturned":
case "userPrincipalNameReturned": return java.lang.Boolean.class;
default: return null;
@@ -203,6 +215,10 @@ public class DataLakeComponentConfigurer extends
PropertyConfigurerSupport imple
case "regex": return getOrCreateConfiguration(target).getRegex();
case "retainuncommiteddata":
case "retainUncommitedData": return
getOrCreateConfiguration(target).getRetainUncommitedData();
+ case "sascredential":
+ case "sasCredential": return
getOrCreateConfiguration(target).getSasCredential();
+ case "sassignature":
+ case "sasSignature": return
getOrCreateConfiguration(target).getSasSignature();
case "serviceclient":
case "serviceClient": return
getOrCreateConfiguration(target).getServiceClient();
case "sharedkeycredential":
@@ -211,6 +227,8 @@ public class DataLakeComponentConfigurer extends
PropertyConfigurerSupport imple
case "tenantId": return getOrCreateConfiguration(target).getTenantId();
case "timeout": return getOrCreateConfiguration(target).getTimeout();
case "umask": return getOrCreateConfiguration(target).getUmask();
+ case "usedefaultidentity":
+ case "useDefaultIdentity": return
getOrCreateConfiguration(target).getUseDefaultIdentity();
case "userprincipalnamereturned":
case "userPrincipalNameReturned": return
getOrCreateConfiguration(target).getUserPrincipalNameReturned();
default: return null;
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointConfigurer.java
b/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointConfigurer.java
index d084784c20b..7d5278d69fb 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointConfigurer.java
+++
b/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointConfigurer.java
@@ -85,6 +85,10 @@ public class DataLakeEndpointConfigurer extends
PropertyConfigurerSupport implem
case "retainUncommitedData":
target.getConfiguration().setRetainUncommitedData(property(camelContext,
java.lang.Boolean.class, value)); return true;
case "runlogginglevel":
case "runLoggingLevel":
target.setRunLoggingLevel(property(camelContext,
org.apache.camel.LoggingLevel.class, value)); return true;
+ case "sascredential":
+ case "sasCredential":
target.getConfiguration().setSasCredential(property(camelContext,
com.azure.core.credential.AzureSasCredential.class, value)); return true;
+ case "sassignature":
+ case "sasSignature":
target.getConfiguration().setSasSignature(property(camelContext,
java.lang.String.class, value)); return true;
case "scheduledexecutorservice":
case "scheduledExecutorService":
target.setScheduledExecutorService(property(camelContext,
java.util.concurrent.ScheduledExecutorService.class, value)); return true;
case "scheduler": target.setScheduler(property(camelContext,
java.lang.Object.class, value)); return true;
@@ -104,6 +108,8 @@ public class DataLakeEndpointConfigurer extends
PropertyConfigurerSupport implem
case "timeUnit": target.setTimeUnit(property(camelContext,
java.util.concurrent.TimeUnit.class, value)); return true;
case "timeout":
target.getConfiguration().setTimeout(property(camelContext,
java.time.Duration.class, value)); return true;
case "umask":
target.getConfiguration().setUmask(property(camelContext,
java.lang.String.class, value)); return true;
+ case "usedefaultidentity":
+ case "useDefaultIdentity":
target.getConfiguration().setUseDefaultIdentity(property(camelContext,
java.lang.Boolean.class, value)); return true;
case "usefixeddelay":
case "useFixedDelay": target.setUseFixedDelay(property(camelContext,
boolean.class, value)); return true;
case "userprincipalnamereturned":
@@ -184,6 +190,10 @@ public class DataLakeEndpointConfigurer extends
PropertyConfigurerSupport implem
case "retainUncommitedData": return java.lang.Boolean.class;
case "runlogginglevel":
case "runLoggingLevel": return org.apache.camel.LoggingLevel.class;
+ case "sascredential":
+ case "sasCredential": return
com.azure.core.credential.AzureSasCredential.class;
+ case "sassignature":
+ case "sasSignature": return java.lang.String.class;
case "scheduledexecutorservice":
case "scheduledExecutorService": return
java.util.concurrent.ScheduledExecutorService.class;
case "scheduler": return java.lang.Object.class;
@@ -203,6 +213,8 @@ public class DataLakeEndpointConfigurer extends
PropertyConfigurerSupport implem
case "timeUnit": return java.util.concurrent.TimeUnit.class;
case "timeout": return java.time.Duration.class;
case "umask": return java.lang.String.class;
+ case "usedefaultidentity":
+ case "useDefaultIdentity": return java.lang.Boolean.class;
case "usefixeddelay":
case "useFixedDelay": return boolean.class;
case "userprincipalnamereturned":
@@ -279,6 +291,10 @@ public class DataLakeEndpointConfigurer extends
PropertyConfigurerSupport implem
case "retainUncommitedData": return
target.getConfiguration().getRetainUncommitedData();
case "runlogginglevel":
case "runLoggingLevel": return target.getRunLoggingLevel();
+ case "sascredential":
+ case "sasCredential": return
target.getConfiguration().getSasCredential();
+ case "sassignature":
+ case "sasSignature": return
target.getConfiguration().getSasSignature();
case "scheduledexecutorservice":
case "scheduledExecutorService": return
target.getScheduledExecutorService();
case "scheduler": return target.getScheduler();
@@ -298,6 +314,8 @@ public class DataLakeEndpointConfigurer extends
PropertyConfigurerSupport implem
case "timeUnit": return target.getTimeUnit();
case "timeout": return target.getConfiguration().getTimeout();
case "umask": return target.getConfiguration().getUmask();
+ case "usedefaultidentity":
+ case "useDefaultIdentity": return
target.getConfiguration().getUseDefaultIdentity();
case "usefixeddelay":
case "useFixedDelay": return target.isUseFixedDelay();
case "userprincipalnamereturned":
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointUriFactory.java
b/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointUriFactory.java
index d4bced97a9d..57a33d11d6c 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointUriFactory.java
+++
b/components/camel-azure/camel-azure-storage-datalake/src/generated/java/org/apache/camel/component/azure/storage/datalake/DataLakeEndpointUriFactory.java
@@ -21,7 +21,7 @@ public class DataLakeEndpointUriFactory extends
org.apache.camel.support.compone
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(52);
+ Set<String> props = new HashSet<>(55);
props.add("accountKey");
props.add("accountName");
props.add("backoffErrorThreshold");
@@ -61,6 +61,8 @@ public class DataLakeEndpointUriFactory extends
org.apache.camel.support.compone
props.add("repeatCount");
props.add("retainUncommitedData");
props.add("runLoggingLevel");
+ props.add("sasCredential");
+ props.add("sasSignature");
props.add("scheduledExecutorService");
props.add("scheduler");
props.add("schedulerProperties");
@@ -72,10 +74,17 @@ public class DataLakeEndpointUriFactory extends
org.apache.camel.support.compone
props.add("timeUnit");
props.add("timeout");
props.add("umask");
+ props.add("useDefaultIdentity");
props.add("useFixedDelay");
props.add("userPrincipalNameReturned");
PROPERTY_NAMES = Collections.unmodifiableSet(props);
- SECRET_PROPERTY_NAMES = Collections.emptySet();
+ Set<String> secretProps = new HashSet<>(5);
+ secretProps.add("accountKey");
+ secretProps.add("clientSecret");
+ secretProps.add("clientSecretCredential");
+ secretProps.add("sasCredential");
+ secretProps.add("sasSignature");
+ SECRET_PROPERTY_NAMES = Collections.unmodifiableSet(secretProps);
Set<String> prefixes = new HashSet<>(1);
prefixes.add("scheduler.");
MULTI_VALUE_PREFIXES = Collections.unmodifiableSet(prefixes);
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/generated/resources/org/apache/camel/component/azure/storage/datalake/azure-storage-datalake.json
b/components/camel-azure/camel-azure-storage-datalake/src/generated/resources/org/apache/camel/component/azure/storage/datalake/azure-storage-datalake.json
index 46c4caa1984..14d0f33f702 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/generated/resources/org/apache/camel/component/azure/storage/datalake/azure-storage-datalake.json
+++
b/components/camel-azure/camel-azure-storage-datalake/src/generated/resources/org/apache/camel/component/azure/storage/datalake/azure-storage-datalake.json
@@ -22,10 +22,7 @@
"lenientProperties": false
},
"componentProperties": {
- "accountKey": { "kind": "property", "displayName": "Account Key", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
"clientId": { "kind": "property", "displayName": "Client Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client id for azure
account" },
- "clientSecret": { "kind": "property", "displayName": "Client Secret",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
- "clientSecretCredential": { "kind": "property", "displayName": "Client
Secret Credential", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.azure.identity.ClientSecretCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
"close": { "kind": "property", "displayName": "Close", "group": "common",
"label": "", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Whether or not a file
changed event raised indicates completion (true) or modification (false)" },
"closeStreamAfterRead": { "kind": "property", "displayName": "Close Stream
After Read", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "check for closing stream
after read" },
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description":
"configuration object for datalake" },
@@ -54,7 +51,13 @@
"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 [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.datalake.DataLakeOperationsDefinition",
"enum": [ "listFileSystem", "listFiles" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "listFileSystem", "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField" [...]
- "autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ "autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ "accountKey": { "kind": "property", "displayName": "Account Key", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
+ "clientSecret": { "kind": "property", "displayName": "Client Secret",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
+ "clientSecretCredential": { "kind": "property", "displayName": "Client
Secret Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.identity.ClientSecretCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
+ "sasCredential": { "kind": "property", "displayName": "Sas Credential",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "com.azure.core.credential.AzureSasCredential", "deprecated":
false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token credential" },
+ "sasSignature": { "kind": "property", "displayName": "Sas Signature",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token signature" },
+ "useDefaultIdentity": { "kind": "property", "displayName": "Use Default
Identity", "group": "security", "label": "security", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Use default identity" }
},
"headers": {
"CamelAzureStorageDataLakeListFileSystemsOptions": { "kind": "header",
"displayName": "", "group": "from user", "label": "from user", "required":
false, "javaType": "ListFileSystemsOptions", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description":
"Defines options available to configure the behavior of a call to
listFileSystemsSegment on a DataLakeServiceAsyncClient object. Null may be
passed.", "constantName": "org.apache.camel.component.azure. [...]
@@ -117,15 +120,14 @@
"CamelAzureStorageDataLakeProgressConsumer": { "kind": "header",
"displayName": "", "group": "from user", "label": "from user", "required":
false, "javaType": "Consumer<FileQueryProgress>", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description":
"Sets progress consumer for file query", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#PROGRESS_CONSUMER"
},
"CamelAzureStorageDataLakeQueryOptions": { "kind": "header",
"displayName": "", "group": "from user", "label": "from user", "required":
false, "javaType": "FileQueryOptions", "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "description": "Optional parameters
for File Query.", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#QUERY_OPTIONS"
},
"CamelAzureStorageDataLakePermission": { "kind": "header", "displayName":
"", "group": "from user", "label": "from user", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets the permission for file.",
"constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#PERMISSION"
},
- "CamelAzureStorageDataLakeUmask": { "kind": "header", "displayName": "",
"group": "from user", "label": "from user", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets the umask for file.", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#UMASK" }
+ "CamelAzureStorageDataLakeUmask": { "kind": "header", "displayName": "",
"group": "from user", "label": "from user", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets the umask for file.", "constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#UMASK" },
+ "CamelAzureStorageDataLakeFileClient": { "kind": "header", "displayName":
"", "group": "from user", "label": "from user", "required": false, "javaType":
"DataLakeFileClient", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Sets the file client to use",
"constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#FILE_CLIENT"
},
+ "CamelAzureStorageDataLakeFlush": { "kind": "header", "displayName": "",
"group": "from user", "label": "from user", "required": false, "javaType":
"Boolean", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Sets whether to flush on append",
"constantName":
"org.apache.camel.component.azure.storage.datalake.DataLakeConstants#FLUSH" }
},
"properties": {
"accountName": { "kind": "path", "displayName": "Account Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "name of the azure
account" },
"fileSystemName": { "kind": "path", "displayName": "File System Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "name of filesystem to be
used" },
- "accountKey": { "kind": "parameter", "displayName": "Account Key",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
"clientId": { "kind": "parameter", "displayName": "Client Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client id for azure
account" },
- "clientSecret": { "kind": "parameter", "displayName": "Client Secret",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
- "clientSecretCredential": { "kind": "parameter", "displayName": "Client
Secret Credential", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.azure.identity.ClientSecretCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
"close": { "kind": "parameter", "displayName": "Close", "group": "common",
"label": "", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Whether or not a file
changed event raised indicates completion (true) or modification (false)" },
"closeStreamAfterRead": { "kind": "parameter", "displayName": "Close
Stream After Read", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "check for closing stream
after read" },
"dataCount": { "kind": "parameter", "displayName": "Data Count", "group":
"common", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Long", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "count number of bytes to
download" },
@@ -171,6 +173,12 @@
"schedulerProperties": { "kind": "parameter", "displayName": "Scheduler
Properties", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.util.Map<java.lang.String,
java.lang.Object>", "prefix": "scheduler.", "multiValue": true, "deprecated":
false, "autowired": false, "secret": false, "description": "To configure
additional properties when using a custom scheduler or any of the Quartz,
Spring based scheduler." },
"startScheduler": { "kind": "parameter", "displayName": "Start Scheduler",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether the scheduler
should be auto started." },
"timeUnit": { "kind": "parameter", "displayName": "Time Unit", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"object", "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS",
"MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"MILLISECONDS", "description": "Time unit for initialDelay and delay options."
},
- "useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Controls if fixed delay
or fixed rate is used. See ScheduledExecutorService in JDK for details." }
+ "useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Controls if fixed delay
or fixed rate is used. See ScheduledExecutorService in JDK for details." },
+ "accountKey": { "kind": "parameter", "displayName": "Account Key",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
+ "clientSecret": { "kind": "parameter", "displayName": "Client Secret",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
+ "clientSecretCredential": { "kind": "parameter", "displayName": "Client
Secret Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.identity.ClientSecretCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret credential
for authentication" },
+ "sasCredential": { "kind": "parameter", "displayName": "Sas Credential",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "com.azure.core.credential.AzureSasCredential", "deprecated":
false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token credential" },
+ "sasSignature": { "kind": "parameter", "displayName": "Sas Signature",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "SAS token signature" },
+ "useDefaultIdentity": { "kind": "parameter", "displayName": "Use Default
Identity", "group": "security", "label": "security", "required": false, "type":
"boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "Use default identity" }
}
}
diff --git
a/core/camel-util/src/main/java/org/apache/camel/util/SensitiveUtils.java
b/core/camel-util/src/main/java/org/apache/camel/util/SensitiveUtils.java
index c887e52db9e..dbf6f20183a 100644
--- a/core/camel-util/src/main/java/org/apache/camel/util/SensitiveUtils.java
+++ b/core/camel-util/src/main/java/org/apache/camel/util/SensitiveUtils.java
@@ -47,6 +47,7 @@ public final class SensitiveUtils {
"cipherkey",
"clientid",
"clientsecret",
+ "clientsecretcredential",
"connectionstring",
"consumerkey",
"consumersecret",
@@ -77,7 +78,9 @@ public final class SensitiveUtils {
"publishkey",
"queueownerawsaccountid",
"refreshtoken",
+ "sascredential",
"sasljaasconfig",
+ "sassignature",
"secretkey",
"securerandom",
"sharedaccesskey",
@@ -122,6 +125,7 @@ public final class SensitiveUtils {
+ "|\\Qcipherkey\\E"
+ "|\\Qclientid\\E"
+ "|\\Qclientsecret\\E"
+ +
"|\\Qclientsecretcredential\\E"
+ "|\\Qconnectionstring\\E"
+ "|\\Qconsumerkey\\E"
+ "|\\Qconsumersecret\\E"
@@ -152,7 +156,9 @@ public final class SensitiveUtils {
+ "|\\Qpublishkey\\E"
+
"|\\Qqueueownerawsaccountid\\E"
+ "|\\Qrefreshtoken\\E"
+ + "|\\Qsascredential\\E"
+ "|\\Qsasljaasconfig\\E"
+ + "|\\Qsassignature\\E"
+ "|\\Qsecretkey\\E"
+ "|\\Qsecurerandom\\E"
+ "|\\Qsharedaccesskey\\E"
@@ -172,7 +178,7 @@ public final class SensitiveUtils {
+ "|\\Qverificationcode\\E"
+
"|\\Qwebhookverifytoken\\E"
+
"|\\Qzookeeperpassword\\E"
- // SENSITIVE-PATTERN: END
+ // SENSITIVE-PATTERN: END
;
private SensitiveUtils() {
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageDatalakeComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageDatalakeComponentBuilderFactory.java
index 2641397ca89..44207c2cfd4 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageDatalakeComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageDatalakeComponentBuilderFactory.java
@@ -50,21 +50,6 @@ public interface AzureStorageDatalakeComponentBuilderFactory
{
interface AzureStorageDatalakeComponentBuilder
extends
ComponentBuilder<DataLakeComponent> {
- /**
- * account key for authentication.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param accountKey the value to set
- * @return the dsl builder
- */
- default AzureStorageDatalakeComponentBuilder accountKey(
- java.lang.String accountKey) {
- doSetProperty("accountKey", accountKey);
- return this;
- }
/**
* client id for azure account.
*
@@ -80,38 +65,6 @@ public interface AzureStorageDatalakeComponentBuilderFactory
{
doSetProperty("clientId", clientId);
return this;
}
- /**
- * client secret for azure account.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param clientSecret the value to set
- * @return the dsl builder
- */
- default AzureStorageDatalakeComponentBuilder clientSecret(
- java.lang.String clientSecret) {
- doSetProperty("clientSecret", clientSecret);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option is a:
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default AzureStorageDatalakeComponentBuilder clientSecretCredential(
- com.azure.identity.ClientSecretCredential
clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
/**
* Whether or not a file changed event raised indicates completion
* (true) or modification (false).
@@ -577,6 +530,100 @@ public interface
AzureStorageDatalakeComponentBuilderFactory {
doSetProperty("autowiredEnabled", autowiredEnabled);
return this;
}
+ /**
+ * account key for authentication.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param accountKey the value to set
+ * @return the dsl builder
+ */
+ default AzureStorageDatalakeComponentBuilder accountKey(
+ java.lang.String accountKey) {
+ doSetProperty("accountKey", accountKey);
+ return this;
+ }
+ /**
+ * client secret for azure account.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param clientSecret the value to set
+ * @return the dsl builder
+ */
+ default AzureStorageDatalakeComponentBuilder clientSecret(
+ java.lang.String clientSecret) {
+ doSetProperty("clientSecret", clientSecret);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option is a:
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default AzureStorageDatalakeComponentBuilder clientSecretCredential(
+ com.azure.identity.ClientSecretCredential
clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option is a:
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default AzureStorageDatalakeComponentBuilder sasCredential(
+ com.azure.core.credential.AzureSasCredential sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token signature.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param sasSignature the value to set
+ * @return the dsl builder
+ */
+ default AzureStorageDatalakeComponentBuilder sasSignature(
+ java.lang.String sasSignature) {
+ doSetProperty("sasSignature", sasSignature);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option is a: <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default AzureStorageDatalakeComponentBuilder useDefaultIdentity(
+ java.lang.Boolean useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
}
class AzureStorageDatalakeComponentBuilderImpl
@@ -601,10 +648,7 @@ public interface
AzureStorageDatalakeComponentBuilderFactory {
String name,
Object value) {
switch (name) {
- case "accountKey": getOrCreateConfiguration((DataLakeComponent)
component).setAccountKey((java.lang.String) value); return true;
case "clientId": getOrCreateConfiguration((DataLakeComponent)
component).setClientId((java.lang.String) value); return true;
- case "clientSecret": getOrCreateConfiguration((DataLakeComponent)
component).setClientSecret((java.lang.String) value); return true;
- case "clientSecretCredential":
getOrCreateConfiguration((DataLakeComponent)
component).setClientSecretCredential((com.azure.identity.ClientSecretCredential)
value); return true;
case "close": getOrCreateConfiguration((DataLakeComponent)
component).setClose((java.lang.Boolean) value); return true;
case "closeStreamAfterRead":
getOrCreateConfiguration((DataLakeComponent)
component).setCloseStreamAfterRead((java.lang.Boolean) value); return true;
case "configuration": ((DataLakeComponent)
component).setConfiguration((org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration)
value); return true;
@@ -634,6 +678,12 @@ public interface
AzureStorageDatalakeComponentBuilderFactory {
case "lazyStartProducer": ((DataLakeComponent)
component).setLazyStartProducer((boolean) value); return true;
case "operation": getOrCreateConfiguration((DataLakeComponent)
component).setOperation((org.apache.camel.component.azure.storage.datalake.DataLakeOperationsDefinition)
value); return true;
case "autowiredEnabled": ((DataLakeComponent)
component).setAutowiredEnabled((boolean) value); return true;
+ case "accountKey": getOrCreateConfiguration((DataLakeComponent)
component).setAccountKey((java.lang.String) value); return true;
+ case "clientSecret": getOrCreateConfiguration((DataLakeComponent)
component).setClientSecret((java.lang.String) value); return true;
+ case "clientSecretCredential":
getOrCreateConfiguration((DataLakeComponent)
component).setClientSecretCredential((com.azure.identity.ClientSecretCredential)
value); return true;
+ case "sasCredential": getOrCreateConfiguration((DataLakeComponent)
component).setSasCredential((com.azure.core.credential.AzureSasCredential)
value); return true;
+ case "sasSignature": getOrCreateConfiguration((DataLakeComponent)
component).setSasSignature((java.lang.String) value); return true;
+ case "useDefaultIdentity":
getOrCreateConfiguration((DataLakeComponent)
component).setUseDefaultIdentity((java.lang.Boolean) value); return true;
default: return false;
}
}
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DataLakeEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DataLakeEndpointBuilderFactory.java
index 3994d9b8cfa..8ec35d692c9 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DataLakeEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DataLakeEndpointBuilderFactory.java
@@ -45,20 +45,6 @@ public interface DataLakeEndpointBuilderFactory {
default AdvancedDataLakeEndpointConsumerBuilder advanced() {
return (AdvancedDataLakeEndpointConsumerBuilder) this;
}
- /**
- * account key for authentication.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param accountKey the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointConsumerBuilder accountKey(String accountKey) {
- doSetProperty("accountKey", accountKey);
- return this;
- }
/**
* client id for azure account.
*
@@ -73,54 +59,6 @@ public interface DataLakeEndpointBuilderFactory {
doSetProperty("clientId", clientId);
return this;
}
- /**
- * client secret for azure account.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param clientSecret the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointConsumerBuilder clientSecret(String
clientSecret) {
- doSetProperty("clientSecret", clientSecret);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option is a:
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointConsumerBuilder clientSecretCredential(
- com.azure.identity.ClientSecretCredential
clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option will be converted to a
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointConsumerBuilder clientSecretCredential(
- String clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
/**
* Whether or not a file changed event raised indicates completion
* (true) or modification (false).
@@ -1251,6 +1189,147 @@ public interface DataLakeEndpointBuilderFactory {
doSetProperty("useFixedDelay", useFixedDelay);
return this;
}
+ /**
+ * account key for authentication.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param accountKey the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder accountKey(String accountKey) {
+ doSetProperty("accountKey", accountKey);
+ return this;
+ }
+ /**
+ * client secret for azure account.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param clientSecret the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder clientSecret(String
clientSecret) {
+ doSetProperty("clientSecret", clientSecret);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option is a:
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder clientSecretCredential(
+ com.azure.identity.ClientSecretCredential
clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option will be converted to a
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder clientSecretCredential(
+ String clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option is a:
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder sasCredential(
+ com.azure.core.credential.AzureSasCredential sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option will be converted to a
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder sasCredential(
+ String sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token signature.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param sasSignature the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder sasSignature(String
sasSignature) {
+ doSetProperty("sasSignature", sasSignature);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option is a: <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder useDefaultIdentity(
+ Boolean useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointConsumerBuilder useDefaultIdentity(
+ String useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
}
/**
@@ -1428,20 +1507,6 @@ public interface DataLakeEndpointBuilderFactory {
default AdvancedDataLakeEndpointProducerBuilder advanced() {
return (AdvancedDataLakeEndpointProducerBuilder) this;
}
- /**
- * account key for authentication.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param accountKey the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointProducerBuilder accountKey(String accountKey) {
- doSetProperty("accountKey", accountKey);
- return this;
- }
/**
* client id for azure account.
*
@@ -1456,54 +1521,6 @@ public interface DataLakeEndpointBuilderFactory {
doSetProperty("clientId", clientId);
return this;
}
- /**
- * client secret for azure account.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param clientSecret the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointProducerBuilder clientSecret(String
clientSecret) {
- doSetProperty("clientSecret", clientSecret);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option is a:
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointProducerBuilder clientSecretCredential(
- com.azure.identity.ClientSecretCredential
clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option will be converted to a
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointProducerBuilder clientSecretCredential(
- String clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
/**
* Whether or not a file changed event raised indicates completion
* (true) or modification (false).
@@ -2155,33 +2172,174 @@ public interface DataLakeEndpointBuilderFactory {
doSetProperty("operation", operation);
return this;
}
- }
-
- /**
- * Advanced builder for endpoint producers for the Azure Storage Datalake
- * Service component.
- */
- public interface AdvancedDataLakeEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default DataLakeEndpointProducerBuilder basic() {
- return (DataLakeEndpointProducerBuilder) this;
- }
/**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes
to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring
this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that
when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing
time
- * of the processing.
+ * account key for authentication.
*
- * The option is a: <code>boolean</code> type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Default: false
- * Group: producer (advanced)
+ * Group: security
+ *
+ * @param accountKey the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder accountKey(String accountKey) {
+ doSetProperty("accountKey", accountKey);
+ return this;
+ }
+ /**
+ * client secret for azure account.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param clientSecret the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder clientSecret(String
clientSecret) {
+ doSetProperty("clientSecret", clientSecret);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option is a:
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder clientSecretCredential(
+ com.azure.identity.ClientSecretCredential
clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option will be converted to a
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder clientSecretCredential(
+ String clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option is a:
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder sasCredential(
+ com.azure.core.credential.AzureSasCredential sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option will be converted to a
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder sasCredential(
+ String sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token signature.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param sasSignature the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder sasSignature(String
sasSignature) {
+ doSetProperty("sasSignature", sasSignature);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option is a: <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder useDefaultIdentity(
+ Boolean useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointProducerBuilder useDefaultIdentity(
+ String useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint producers for the Azure Storage Datalake
+ * Service component.
+ */
+ public interface AdvancedDataLakeEndpointProducerBuilder
+ extends
+ EndpointProducerBuilder {
+ default DataLakeEndpointProducerBuilder basic() {
+ return (DataLakeEndpointProducerBuilder) this;
+ }
+ /**
+ * Whether the producer should be started lazy (on the first message).
+ * By starting lazy you can use this to allow CamelContext and routes
to
+ * startup in situations where a producer may otherwise fail during
+ * starting and cause the route to fail being started. By deferring
this
+ * startup to be lazy then the startup failure can be handled during
+ * routing messages via Camel's routing error handlers. Beware that
when
+ * the first message is processed then creating and starting the
+ * producer may take a little time and prolong the total processing
time
+ * of the processing.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer (advanced)
*
* @param lazyStartProducer the value to set
* @return the dsl builder
@@ -2228,20 +2386,6 @@ public interface DataLakeEndpointBuilderFactory {
default AdvancedDataLakeEndpointBuilder advanced() {
return (AdvancedDataLakeEndpointBuilder) this;
}
- /**
- * account key for authentication.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param accountKey the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointBuilder accountKey(String accountKey) {
- doSetProperty("accountKey", accountKey);
- return this;
- }
/**
* client id for azure account.
*
@@ -2256,54 +2400,6 @@ public interface DataLakeEndpointBuilderFactory {
doSetProperty("clientId", clientId);
return this;
}
- /**
- * client secret for azure account.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param clientSecret the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointBuilder clientSecret(String clientSecret) {
- doSetProperty("clientSecret", clientSecret);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option is a:
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointBuilder clientSecretCredential(
- com.azure.identity.ClientSecretCredential
clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
- /**
- * client secret credential for authentication.
- *
- * The option will be converted to a
- * <code>com.azure.identity.ClientSecretCredential</code>
- * type.
- *
- * Group: common
- *
- * @param clientSecretCredential the value to set
- * @return the dsl builder
- */
- default DataLakeEndpointBuilder clientSecretCredential(
- String clientSecretCredential) {
- doSetProperty("clientSecretCredential", clientSecretCredential);
- return this;
- }
/**
* Whether or not a file changed event raised indicates completion
* (true) or modification (false).
@@ -2917,6 +3013,146 @@ public interface DataLakeEndpointBuilderFactory {
doSetProperty("userPrincipalNameReturned",
userPrincipalNameReturned);
return this;
}
+ /**
+ * account key for authentication.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param accountKey the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder accountKey(String accountKey) {
+ doSetProperty("accountKey", accountKey);
+ return this;
+ }
+ /**
+ * client secret for azure account.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param clientSecret the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder clientSecret(String clientSecret) {
+ doSetProperty("clientSecret", clientSecret);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option is a:
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder clientSecretCredential(
+ com.azure.identity.ClientSecretCredential
clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * client secret credential for authentication.
+ *
+ * The option will be converted to a
+ * <code>com.azure.identity.ClientSecretCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param clientSecretCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder clientSecretCredential(
+ String clientSecretCredential) {
+ doSetProperty("clientSecretCredential", clientSecretCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option is a:
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder sasCredential(
+ com.azure.core.credential.AzureSasCredential sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token credential.
+ *
+ * The option will be converted to a
+ *
<code>com.azure.core.credential.AzureSasCredential</code>
+ * type.
+ *
+ * Group: security
+ *
+ * @param sasCredential the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder sasCredential(String sasCredential) {
+ doSetProperty("sasCredential", sasCredential);
+ return this;
+ }
+ /**
+ * SAS token signature.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param sasSignature the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder sasSignature(String sasSignature) {
+ doSetProperty("sasSignature", sasSignature);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option is a: <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder useDefaultIdentity(
+ Boolean useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
+ /**
+ * Use default identity.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Boolean</code> type.
+ *
+ * Group: security
+ *
+ * @param useDefaultIdentity the value to set
+ * @return the dsl builder
+ */
+ default DataLakeEndpointBuilder useDefaultIdentity(
+ String useDefaultIdentity) {
+ doSetProperty("useDefaultIdentity", useDefaultIdentity);
+ return this;
+ }
}
/**
@@ -3879,6 +4115,33 @@ public interface DataLakeEndpointBuilderFactory {
public String azureStorageDataLakeUmask() {
return "AzureStorageDataLakeUmask";
}
+
+ /**
+ * Sets the file client to use.
+ *
+ * The option is a: {@code DataLakeFileClient} type.
+ *
+ * Group: from user
+ *
+ * @return the name of the header {@code
+ * AzureStorageDataLakeFileClient}.
+ */
+ public String azureStorageDataLakeFileClient() {
+ return "AzureStorageDataLakeFileClient";
+ }
+
+ /**
+ * Sets whether to flush on append.
+ *
+ * The option is a: {@code Boolean} type.
+ *
+ * Group: from user
+ *
+ * @return the name of the header {@code AzureStorageDataLakeFlush}.
+ */
+ public String azureStorageDataLakeFlush() {
+ return "AzureStorageDataLakeFlush";
+ }
}
static DataLakeEndpointBuilder endpointBuilder(
String componentName,
