This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new b368a98 Regen
b368a98 is described below
commit b368a9870ccb3ca491cb6417475f506d5993d2e6
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Aug 4 06:52:22 2020 +0200
Regen
---
.../catalog/components/azure-storage-blob.json | 2 +
.../catalog/components/azure-storage-queue.json | 2 +
.../camel/catalog/docs/aws2-kms-component.adoc | 26 +++++++
.../camel/catalog/docs/aws2-mq-component.adoc | 44 +++++++++++
.../camel/catalog/docs/aws2-msk-component.adoc | 45 ++++++++++-
.../catalog/docs/azure-storage-blob-component.adoc | 6 +-
.../docs/azure-storage-queue-component.adoc | 6 +-
.../storage/queue/QueueComponentConfigurer.java | 5 ++
.../storage/queue/QueueEndpointConfigurer.java | 5 ++
.../azure/storage/queue/azure-storage-queue.json | 2 +
.../main/docs/azure-storage-queue-component.adoc | 6 +-
.../generated/java/org/apache/camel/Category.java | 1 -
.../AzureStorageQueueComponentBuilderFactory.java | 16 ++++
.../endpoint/dsl/QueueEndpointBuilderFactory.java | 90 ++++++++++++++++++++++
.../ROOT/pages/azure-storage-queue-component.adoc | 6 +-
15 files changed, 252 insertions(+), 10 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-blob.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-blob.json
index 5742d29..2aa3347 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-blob.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-blob.json
@@ -21,6 +21,7 @@
"lenientProperties": false
},
"componentProperties": {
+ "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in [...]
"blobName": { "kind": "property", "displayName": "Blob Name", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "The blob name, required
for consumer. However on producer, is only required for the operations on the
blob level" },
"blobOffset": { "kind": "property", "displayName": "Blob Offset", "group":
"common", "label": "common", "required": false, "type": "integer", "javaType":
"long", "deprecated": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "Set the blob offset for
the upload or download operations, default is 0" },
"blobType": { "kind": "property", "displayName": "Blob Type", "group":
"common", "label": "common", "required": false, "type": "object", "javaType":
"org.apache.camel.component.azure.storage.blob.BlobType", "enum": [
"blockblob", "appendblob", "pageblob" ], "deprecated": false, "secret": false,
"defaultValue": "blockblob", "configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "The blob type in or [...]
@@ -51,6 +52,7 @@
"properties": {
"accountName": { "kind": "path", "displayName": "Account Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "Azure account name to be
used for authentication with azure blob services" },
"containerName": { "kind": "path", "displayName": "Container Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "The blob container name"
},
+ "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in [...]
"blobName": { "kind": "parameter", "displayName": "Blob Name", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "The blob name, required
for consumer. However on producer, is only required for the operations on the
blob level" },
"blobOffset": { "kind": "parameter", "displayName": "Blob Offset",
"group": "common", "label": "common", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.azure.storage.blob.BlobConfiguration",
"configurationField": "configuration", "description": "Set the blob offset for
the upload or download operations, default is 0" },
"blobServiceClient": { "kind": "parameter", "displayName": "Blob Service
Client", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "com.azure.storage.blob.BlobServiceClient", "deprecated": false,
"secret": false, "description": "Client to a storage account. This client does
not hold any state about a particular storage account but is instead a
convenient way of sending off appropriate requests to the resource on the
service. It may also be used to cons [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-queue.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-queue.json
index 696a231..dbf97b8 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-queue.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-queue.json
@@ -21,6 +21,7 @@
"lenientProperties": false
},
"componentProperties": {
+ "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance i [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"deprecated": false, "secret": false, "description": "The component
configurations" },
"serviceClient": { "kind": "property", "displayName": "Service Client",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.storage.queue.QueueServiceClient", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Service client to a
storage account to interact with the queue service. This client does not hold a
[...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": 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 message and handled by [...]
@@ -40,6 +41,7 @@
"properties": {
"accountName": { "kind": "path", "displayName": "Account Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Azure account name to be
used for authentication with azure queue services" },
"queueName": { "kind": "path", "displayName": "Queue Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "The queue resource name"
},
+ "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance [...]
"serviceClient": { "kind": "parameter", "displayName": "Service Client",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.storage.queue.QueueServiceClient", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Service client to a
storage account to interact with the queue service. This client does not hold
[...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": 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 message and handled b [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "secret": false, "description": "To let the consumer use a
custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled
then this option is not in use. By default the consumer will deal with [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kms-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kms-component.adoc
index 4a0e255..f9d8ebd 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kms-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kms-component.adoc
@@ -157,6 +157,32 @@ from("direct:listKeys")
.to("aws2-kms://test?kmsClient=#amazonKmsClient&operation=listKeys")
--------------------------------------------------------------------------------
+- createKey: this operation will create a key in KMS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:createKey")
+ .to("aws2-kms://test?kmsClient=#amazonKmsClient&operation=createKey")
+--------------------------------------------------------------------------------
+
+- disableKey: this operation will disable a key in KMS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:disableKey")
+ .setHeader(KMS2Constants.KEY_ID, constant("123")
+ .to("aws2-kms://test?kmsClient=#amazonKmsClient&operation=disableKey")
+--------------------------------------------------------------------------------
+
+- enableKey: this operation will enable a key in KMS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:enableKey")
+ .setHeader(KMS2Constants.KEY_ID, constant("123")
+ .to("aws2-kms://test?kmsClient=#amazonKmsClient&operation=enableKey")
+--------------------------------------------------------------------------------
+
== Automatic detection of KmsClient client in registry
The component is capable of detecting the presence of an KmsClient bean into
the registry.
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
index 9233089..efff789 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
@@ -170,6 +170,50 @@ from("direct:listBrokers")
.to("aws2-mq://test?amazonMqClient=#amazonMqClient&operation=listBrokers")
--------------------------------------------------------------------------------
+- createBroker: this operation will create an MQ Broker in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:createBroker")
+ .process(new Processor() {
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setHeader(MQ2Constants.BROKER_NAME, "test");
+
exchange.getIn().setHeader(MQ2Constants.BROKER_DEPLOYMENT_MODE,
DeploymentMode.SINGLE_INSTANCE);
+ exchange.getIn().setHeader(MQ2Constants.BROKER_INSTANCE_TYPE,
"mq.t2.micro");
+ exchange.getIn().setHeader(MQ2Constants.BROKER_ENGINE,
EngineType.ACTIVEMQ.name());
+ exchange.getIn().setHeader(MQ2Constants.BROKER_ENGINE_VERSION,
"5.15.6");
+
exchange.getIn().setHeader(MQ2Constants.BROKER_PUBLICLY_ACCESSIBLE, false);
+ List<User> users = new ArrayList<>();
+ User.Builder user = User.builder();
+ user.username("camel");
+ user.password("camelpwd");
+ users.add(user.build());
+ exchange.getIn().setHeader(MQ2Constants.BROKER_USERS, users);
+
+ }
+ })
+ .to("aws2-mq://test?amazonMqClient=#amazonMqClient&operation=createBroker")
+--------------------------------------------------------------------------------
+
+- deleteBroker: this operation will delete an MQ Broker in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:listBrokers")
+ .setHeader(MQ2Constants.BROKER_ID, constant("123")
+ .to("aws2-mq://test?amazonMqClient=#amazonMqClient&operation=deleteBroker")
+--------------------------------------------------------------------------------
+
+- rebootBroker: this operation will delete an MQ Broker in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:listBrokers")
+ .setHeader(MQ2Constants.BROKER_ID, constant("123")
+ .to("aws2-mq://test?amazonMqClient=#amazonMqClient&operation=rebootBroker")
+--------------------------------------------------------------------------------
+
== Automatic detection of MqClient client in registry
The component is capable of detecting the presence of an MqClient bean into
the registry.
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-msk-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-msk-component.adoc
index 42665df..0800ce7 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-msk-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-msk-component.adoc
@@ -151,7 +151,7 @@ Camel-AWS MSK component provides the following operation on
the producer side:
== Producer Examples
-- listBrokers: this operation will list the available MSK Brokers in AWS
+- listClusters: this operation will list the available MSK Brokers in AWS
[source,java]
--------------------------------------------------------------------------------
@@ -159,6 +159,49 @@ from("direct:listClusters")
.to("aws2-msk://test?mskClient=#amazonMskClient&operation=listClusters")
--------------------------------------------------------------------------------
+- createCluster: this operation will create an MSK Cluster in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:createCluster")
+ .process(new Processor() {
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setHeader(MSK2Constants.CLUSTER_NAME,
"test-kafka");
+
exchange.getIn().setHeader(MSK2Constants.CLUSTER_KAFKA_VERSION, "2.1.1");
+ exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_NUMBER,
2);
+ BrokerNodeGroupInfo groupInfo =
BrokerNodeGroupInfo.builder().build();
+
exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_GROUP_INFO, groupInfo);
+ }
+ })
+ .to("aws2-msk://test?mskClient=#amazonMskClient&operation=createCluster")
+--------------------------------------------------------------------------------
+
+- deleteCluster: this operation will delete an MSK Cluster in AWS
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:deleteCluster")
+ .setHeader(MSK2Constants.CLUSTER_ARN, constant("test-kafka"));
+ .to("aws2-msk://test?mskClient=#amazonMskClient&operation=deleteCluster")
+--------------------------------------------------------------------------------
+
+[source,java]
+--------------------------------------------------------------------------------
+from("direct:createCluster")
+ .process(new Processor() {
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setHeader(MSK2Constants.CLUSTER_NAME,
"test-kafka");
+
exchange.getIn().setHeader(MSK2Constants.CLUSTER_KAFKA_VERSION, "2.1.1");
+ exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_NUMBER,
2);
+ BrokerNodeGroupInfo groupInfo =
BrokerNodeGroupInfo.builder().build();
+
exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_GROUP_INFO, groupInfo);
+ }
+ })
+ .to("aws2-msk://test?mskClient=#amazonMskClient&operation=deleteCluster")
+--------------------------------------------------------------------------------
+
== Automatic detection of KafkaClient client in registry
The component is capable of detecting the presence of an KafkaClient bean into
the registry.
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-blob-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-blob-component.adoc
index 9cbaa02..8310763 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-blob-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-blob-component.adoc
@@ -64,13 +64,14 @@ to("file://blobdirectory");
// component options: START
-The Azure Storage Blob Service component supports 26 options, which are listed
below.
+The Azure Storage Blob Service component supports 27 options, which are listed
below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *blobName* (common) | The blob name, required for consumer. However on
producer, is only required for the operations on the blob level | | String
| *blobOffset* (common) | Set the blob offset for the upload or download
operations, default is 0 | 0 | long
| *blobType* (common) | The blob type in order to initiate the appropriate
settings for each blob type. The value can be one of: blockblob, appendblob,
pageblob | blockblob | BlobType
@@ -120,12 +121,13 @@ with the following path and query parameters:
|===
-=== Query Parameters (29 parameters):
+=== Query Parameters (30 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *blobName* (common) | The blob name, required for consumer. However on
producer, is only required for the operations on the blob level | | String
| *blobOffset* (common) | Set the blob offset for the upload or download
operations, default is 0 | 0 | long
| *blobServiceClient* (common) | Client to a storage account. This client does
not hold any state about a particular storage account but is instead a
convenient way of sending off appropriate requests to the resource on the
service. It may also be used to construct URLs to blobs and containers. This
client contains operations on a service account. Operations on a container are
available on BlobContainerClient through getBlobContainerClient(String), and
operations on a blob are available [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
index 656efd2..45c38df 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
@@ -61,13 +61,14 @@ to("file://queuedirectory");
== URI Options
// component options: START
-The Azure Storage Queue Service component supports 15 options, which are
listed below.
+The Azure Storage Queue Service component supports 16 options, which are
listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configurations | |
QueueConfiguration
| *serviceClient* (common) | Service client to a storage account to interact
with the queue service. This client does not hold any state about a particular
storage account but is instead a convenient way of sending off appropriate
requests to the resource on the service. This client contains all the
operations for interacting with a queue account in Azure Storage. Operations
allowed by the client are creating, listing, and deleting queues, retrieving
and updating properties of the accoun [...]
| *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
@@ -106,12 +107,13 @@ with the following path and query parameters:
|===
-=== Query Parameters (17 parameters):
+=== Query Parameters (18 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *serviceClient* (common) | Service client to a storage account to interact
with the queue service. This client does not hold any state about a particular
storage account but is instead a convenient way of sending off appropriate
requests to the resource on the service. This client contains all the
operations for interacting with a queue account in Azure Storage. Operations
allowed by the client are creating, listing, and deleting queues, retrieving
and updating properties of the accoun [...]
| *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
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
diff --git
a/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueComponentConfigurer.java
b/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueComponentConfigurer.java
index 4f67136..05b21ea 100644
---
a/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueComponentConfigurer.java
+++
b/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueComponentConfigurer.java
@@ -28,6 +28,8 @@ public class QueueComponentConfigurer extends
PropertyConfigurerSupport implemen
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey":
getOrCreateConfiguration(target).setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
getOrCreateConfiguration(target).setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "basicpropertybinding":
case "basicPropertyBinding":
target.setBasicPropertyBinding(property(camelContext, boolean.class, value));
return true;
case "bridgeerrorhandler":
@@ -60,6 +62,7 @@ public class QueueComponentConfigurer extends
PropertyConfigurerSupport implemen
public Map<String, Object> getAllOptions(Object target) {
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("bridgeErrorHandler", boolean.class);
answer.put("configuration",
org.apache.camel.component.azure.storage.queue.QueueConfiguration.class);
@@ -83,6 +86,8 @@ public class QueueComponentConfigurer extends
PropertyConfigurerSupport implemen
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey": return
getOrCreateConfiguration(target).getAccessKey();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
getOrCreateConfiguration(target).isAutoDiscoverClient();
case "basicpropertybinding":
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
diff --git
a/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueEndpointConfigurer.java
b/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueEndpointConfigurer.java
index f6c4f8f..229aeb2 100644
---
a/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueEndpointConfigurer.java
+++
b/components/camel-azure-storage-queue/src/generated/java/org/apache/camel/component/azure/storage/queue/QueueEndpointConfigurer.java
@@ -21,6 +21,8 @@ public class QueueEndpointConfigurer extends
PropertyConfigurerSupport implement
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey":
target.getConfiguration().setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
target.getConfiguration().setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "basicpropertybinding":
case "basicPropertyBinding":
target.setBasicPropertyBinding(property(camelContext, boolean.class, value));
return true;
case "bridgeerrorhandler":
@@ -57,6 +59,7 @@ public class QueueEndpointConfigurer extends
PropertyConfigurerSupport implement
public Map<String, Object> getAllOptions(Object target) {
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("bridgeErrorHandler", boolean.class);
answer.put("createQueue", boolean.class);
@@ -82,6 +85,8 @@ public class QueueEndpointConfigurer extends
PropertyConfigurerSupport implement
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey": return target.getConfiguration().getAccessKey();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
target.getConfiguration().isAutoDiscoverClient();
case "basicpropertybinding":
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
diff --git
a/components/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
b/components/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
index 696a231..dbf97b8 100644
---
a/components/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
+++
b/components/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
@@ -21,6 +21,7 @@
"lenientProperties": false
},
"componentProperties": {
+ "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance i [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"deprecated": false, "secret": false, "description": "The component
configurations" },
"serviceClient": { "kind": "property", "displayName": "Service Client",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.storage.queue.QueueServiceClient", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Service client to a
storage account to interact with the queue service. This client does not hold a
[...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": 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 message and handled by [...]
@@ -40,6 +41,7 @@
"properties": {
"accountName": { "kind": "path", "displayName": "Account Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Azure account name to be
used for authentication with azure queue services" },
"queueName": { "kind": "path", "displayName": "Queue Name", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "The queue resource name"
},
+ "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance [...]
"serviceClient": { "kind": "parameter", "displayName": "Service Client",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.storage.queue.QueueServiceClient", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Service client to a
storage account to interact with the queue service. This client does not hold
[...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": 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 message and handled b [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "secret": false, "description": "To let the consumer use a
custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled
then this option is not in use. By default the consumer will deal with [...]
diff --git
a/components/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
b/components/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
index 656efd2..45c38df 100644
---
a/components/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
+++
b/components/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
@@ -61,13 +61,14 @@ to("file://queuedirectory");
== URI Options
// component options: START
-The Azure Storage Queue Service component supports 15 options, which are
listed below.
+The Azure Storage Queue Service component supports 16 options, which are
listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configurations | |
QueueConfiguration
| *serviceClient* (common) | Service client to a storage account to interact
with the queue service. This client does not hold any state about a particular
storage account but is instead a convenient way of sending off appropriate
requests to the resource on the service. This client contains all the
operations for interacting with a queue account in Azure Storage. Operations
allowed by the client are creating, listing, and deleting queues, retrieving
and updating properties of the accoun [...]
| *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
@@ -106,12 +107,13 @@ with the following path and query parameters:
|===
-=== Query Parameters (17 parameters):
+=== Query Parameters (18 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *serviceClient* (common) | Service client to a storage account to interact
with the queue service. This client does not hold any state about a particular
storage account but is instead a convenient way of sending off appropriate
requests to the resource on the service. This client contains all the
operations for interacting with a queue account in Azure Storage. Operations
allowed by the client are creating, listing, and deleting queues, retrieving
and updating properties of the accoun [...]
| *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
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
diff --git a/core/camel-api/src/generated/java/org/apache/camel/Category.java
b/core/camel-api/src/generated/java/org/apache/camel/Category.java
index e906a02..955913a 100644
--- a/core/camel-api/src/generated/java/org/apache/camel/Category.java
+++ b/core/camel-api/src/generated/java/org/apache/camel/Category.java
@@ -30,7 +30,6 @@ public enum Category {
BITCOIN("bitcoin"),
BLOCKCHAIN("blockchain"),
CACHE("cache"),
- CAMEL_K("camel-k"),
CHAT("chat"),
CHATSCRIPT("chatscript"),
CLOUD("cloud"),
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
index f680a84..406e060 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
@@ -51,6 +51,21 @@ public interface AzureStorageQueueComponentBuilderFactory {
extends
ComponentBuilder<QueueComponent> {
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AzureStorageQueueComponentBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* The component configurations.
*
* The option is a:
@@ -306,6 +321,7 @@ public interface AzureStorageQueueComponentBuilderFactory {
String name,
Object value) {
switch (name) {
+ case "autoDiscoverClient":
getOrCreateConfiguration((QueueComponent)
component).setAutoDiscoverClient((boolean) value); return true;
case "configuration": ((QueueComponent)
component).setConfiguration((org.apache.camel.component.azure.storage.queue.QueueConfiguration)
value); return true;
case "serviceClient": getOrCreateConfiguration((QueueComponent)
component).setServiceClient((com.azure.storage.queue.QueueServiceClient)
value); return true;
case "bridgeErrorHandler": ((QueueComponent)
component).setBridgeErrorHandler((boolean) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
index 4ed969d..ee8847b 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
@@ -45,6 +45,36 @@ public interface QueueEndpointBuilderFactory {
return (AdvancedQueueEndpointConsumerBuilder) this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default QueueEndpointConsumerBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default QueueEndpointConsumerBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Service client to a storage account to interact with the queue
* service. This client does not hold any state about a particular
* storage account but is instead a convenient way of sending off
@@ -449,6 +479,36 @@ public interface QueueEndpointBuilderFactory {
return (AdvancedQueueEndpointProducerBuilder) this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default QueueEndpointProducerBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default QueueEndpointProducerBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Service client to a storage account to interact with the queue
* service. This client does not hold any state about a particular
* storage account but is instead a convenient way of sending off
@@ -851,6 +911,36 @@ public interface QueueEndpointBuilderFactory {
return (AdvancedQueueEndpointBuilder) this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default QueueEndpointBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default QueueEndpointBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Service client to a storage account to interact with the queue
* service. This client does not hold any state about a particular
* storage account but is instead a convenient way of sending off
diff --git
a/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
b/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
index ff9769d..5eb3d59 100644
--- a/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
+++ b/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
@@ -63,13 +63,14 @@ to("file://queuedirectory");
== URI Options
// component options: START
-The Azure Storage Queue Service component supports 15 options, which are
listed below.
+The Azure Storage Queue Service component supports 16 options, which are
listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configurations | |
QueueConfiguration
| *serviceClient* (common) | Service client to a storage account to interact
with the queue service. This client does not hold any state about a particular
storage account but is instead a convenient way of sending off appropriate
requests to the resource on the service. This client contains all the
operations for interacting with a queue account in Azure Storage. Operations
allowed by the client are creating, listing, and deleting queues, retrieving
and updating properties of the accoun [...]
| *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
@@ -108,12 +109,13 @@ with the following path and query parameters:
|===
-=== Query Parameters (17 parameters):
+=== Query Parameters (18 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *serviceClient* (common) | Service client to a storage account to interact
with the queue service. This client does not hold any state about a particular
storage account but is instead a convenient way of sending off appropriate
requests to the resource on the service. This client contains all the
operations for interacting with a queue account in Azure Storage. Operations
allowed by the client are creating, listing, and deleting queues, retrieving
and updating properties of the accoun [...]
| *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
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
