You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by oa...@apache.org on 2021/05/04 08:25:16 UTC
[camel-spring-boot] branch main updated: CAMEL-15655: Add Camel
Azure CosmosDB Starter (#326)
This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new ed6bd34 CAMEL-15655: Add Camel Azure CosmosDB Starter (#326)
ed6bd34 is described below
commit ed6bd340b2a66445a5d53ed441408305e143faac
Author: Omar Al-Safi <om...@gmail.com>
AuthorDate: Tue May 4 10:25:07 2021 +0200
CAMEL-15655: Add Camel Azure CosmosDB Starter (#326)
* CAMEL-15655: Add Camel Azure CosmosDB Starter
* Add docs
---
.../camel/springboot/catalog/components.properties | 1 +
.../catalog/components/azure-cosmosdb.json | 88 ++++
components-starter/README.adoc | 2 +
.../camel-azure-cosmosdb-starter/pom.xml | 48 ++
.../src/main/docs/azure-cosmosdb-starter.adoc | 60 +++
.../CosmosDbComponentAutoConfiguration.java | 79 ++++
.../springboot/CosmosDbComponentConfiguration.java | 498 +++++++++++++++++++++
.../springboot/CosmosDbComponentConverter.java | 75 ++++
.../src/main/resources/META-INF/LICENSE.txt | 203 +++++++++
.../src/main/resources/META-INF/NOTICE.txt | 11 +
.../src/main/resources/META-INF/spring.factories | 21 +
.../src/main/resources/META-INF/spring.provides | 17 +
components-starter/pom.xml | 1 +
.../modules/ROOT/pages/azure-cosmosdb-starter.adoc | 60 +++
docs/modules/ROOT/pages/list.adoc | 2 +
.../itest/springboot/CamelAzureCosmosdbTest.java | 47 ++
tooling/camel-spring-boot-bom/pom.xml | 5 +
tooling/camel-spring-boot-dependencies/pom.xml | 5 +
18 files changed, 1223 insertions(+)
diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
index d2dc10f..a6ab8c9 100644
--- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
+++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
@@ -40,6 +40,7 @@ aws2-sns
aws2-sqs
aws2-sts
aws2-translate
+azure-cosmosdb
azure-eventhubs
azure-storage-blob
azure-storage-datalake
diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-cosmosdb.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-cosmosdb.json
new file mode 100644
index 0000000..0df7f2e
--- /dev/null
+++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-cosmosdb.json
@@ -0,0 +1,88 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "azure-cosmosdb",
+ "title": "Azure CosmosDB",
+ "description": "Azure Cosmos DB is Microsofts globally distributed, multi-model database service for operational and analytics workloads. It offers multi-mastering feature by automatically scaling throughput, compute, and storage. This component interacts with Azure CosmosDB through Azure SQL API",
+ "deprecated": false,
+ "firstVersion": "3.10.0",
+ "label": "cloud,database",
+ "javaType": "org.apache.camel.component.azure.cosmosdb.CosmosDbComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel.springboot",
+ "artifactId": "camel-azure-cosmosdb-starter",
+ "version": "3.10.0-SNAPSHOT",
+ "scheme": "azure-cosmosdb",
+ "extendsScheme": "",
+ "syntax": "azure-cosmosdb:databaseName\/containerName",
+ "async": false,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
+ "componentProperties": {
+ "clientTelemetryEnabled": { "kind": "property", "displayName": "Client Telemetry Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the flag to enable client telemetry which will periodically collect [...]
+ "configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configurations" },
+ "connectionSharingAcrossClientsEnabled": { "kind": "property", "displayName": "Connection Sharing Across Clients Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Enables connections sharing across multip [...]
+ "consistencyLevel": { "kind": "property", "displayName": "Consistency Level", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.azure.cosmos.ConsistencyLevel", "enum": [ "Strong", "BoundedStaleness", "Session", "Eventual", "ConsistentPrefix" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "SESSION", "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "conf [...]
+ "containerPartitionKeyPath": { "kind": "property", "displayName": "Container Partition Key Path", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the container partition key path." },
+ "contentResponseOnWriteEnabled": { "kind": "property", "displayName": "Content Response On Write Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the boolean to only return the headers and status cod [...]
+ "cosmosAsyncClient": { "kind": "property", "displayName": "Cosmos Async Client", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.azure.cosmos.CosmosAsyncClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Inject an external CosmosAsyncClient into the component wh [...]
+ "createContainerIfNotExists": { "kind": "property", "displayName": "Create Container If Not Exists", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos container automatica [...]
+ "createDatabaseIfNotExists": { "kind": "property", "displayName": "Create Database If Not Exists", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos database automatically [...]
+ "databaseEndpoint": { "kind": "property", "displayName": "Database Endpoint", "group": "common", "label": "common", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the Azure Cosmos database endpoint the component will connect to." },
+ "multipleWriteRegionsEnabled": { "kind": "property", "displayName": "Multiple Write Regions Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the flag to enable writes on any regions for geo-replicate [...]
+ "preferredRegions": { "kind": "property", "displayName": "Preferred Regions", "group": "common", "label": "common", "required": false, "type": "array", "javaType": "java.util.List<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the preferred regions for geo-replicated database accounts. For example, East US [...]
+ "readRequestsFallbackEnabled": { "kind": "property", "displayName": "Read Requests Fallback Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets whether to allow for reads to go to multiple regions confi [...]
+ "throughputProperties": { "kind": "property", "displayName": "Throughput Properties", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.ThroughputProperties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets throughput of the resources in the Azure Cosmos DB service." },
+ "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 [...]
+ "changeFeedProcessorOptions": { "kind": "property", "displayName": "Change Feed Processor Options", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.ChangeFeedProcessorOptions", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the ChangeFeedProcessorOptions to be [...]
+ "createLeaseContainerIfNotExists": { "kind": "property", "displayName": "Create Lease Container If Not Exists", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos lease [...]
+ "createLeaseDatabaseIfNotExists": { "kind": "property", "displayName": "Create Lease Database If Not Exists", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos lease d [...]
+ "hostName": { "kind": "property", "displayName": "Host Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the hostname. The host: a host is an application instance that uses the change feed processor to listen for [...]
+ "leaseContainerName": { "kind": "property", "displayName": "Lease Container Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "camel-lease", "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the lease container which acts as a state storage and co [...]
+ "leaseDatabaseName": { "kind": "property", "displayName": "Lease Database Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the lease database where the leaseContainerName will be stored. If it is not specified, t [...]
+ "itemId": { "kind": "property", "displayName": "Item Id", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the itemId in case needed for operation on item like delete, replace" },
+ "itemPartitionKey": { "kind": "property", "displayName": "Item Partition Key", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.PartitionKey", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets partition key. Represents a partition key value in the Azure Cosmos DB [...]
+ "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.cosmosdb.CosmosDbOperationsDefinition", "enum": [ "listDatabases", "createDatabase", "queryDatabases", "deleteDatabase", "createContainer", "replaceDatabaseThroughput", "listContainers", "queryContainers", "deleteContainer", "replaceContainerThroughput", "createItem", "upsertItem", "deleteItem", "re [...]
+ "query": { "kind": "property", "displayName": "Query", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "An SQL query to execute on a given resources. To learn more about Cosmos SQL API, check this link {link https:\/\/docs.m [...]
+ "queryRequestOptions": { "kind": "property", "displayName": "Query Request Options", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.CosmosQueryRequestOptions", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Set additional QueryRequestOptions that can be used with [...]
+ "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": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets either a master or readonly key used to perform authentication for accessing resource." }
+ },
+ "properties": {
+ "databaseName": { "kind": "path", "displayName": "Database Name", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "The name of the Cosmos database that component should connect to. In case you are producing data and have createDatabas [...]
+ "containerName": { "kind": "path", "displayName": "Container Name", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "The name of the Cosmos container that component should connect to. In case you are producing data and have createCont [...]
+ "clientTelemetryEnabled": { "kind": "parameter", "displayName": "Client Telemetry Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the flag to enable client telemetry which will periodically collect [...]
+ "connectionSharingAcrossClientsEnabled": { "kind": "parameter", "displayName": "Connection Sharing Across Clients Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Enables connections sharing across multi [...]
+ "consistencyLevel": { "kind": "parameter", "displayName": "Consistency Level", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.azure.cosmos.ConsistencyLevel", "enum": [ "Strong", "BoundedStaleness", "Session", "Eventual", "ConsistentPrefix" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "SESSION", "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "con [...]
+ "containerPartitionKeyPath": { "kind": "parameter", "displayName": "Container Partition Key Path", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the container partition key path." },
+ "contentResponseOnWriteEnabled": { "kind": "parameter", "displayName": "Content Response On Write Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the boolean to only return the headers and status co [...]
+ "cosmosAsyncClient": { "kind": "parameter", "displayName": "Cosmos Async Client", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.azure.cosmos.CosmosAsyncClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Inject an external CosmosAsyncClient into the component w [...]
+ "createContainerIfNotExists": { "kind": "parameter", "displayName": "Create Container If Not Exists", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos container automatic [...]
+ "createDatabaseIfNotExists": { "kind": "parameter", "displayName": "Create Database If Not Exists", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos database automaticall [...]
+ "databaseEndpoint": { "kind": "parameter", "displayName": "Database Endpoint", "group": "common", "label": "common", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the Azure Cosmos database endpoint the component will connect to." },
+ "multipleWriteRegionsEnabled": { "kind": "parameter", "displayName": "Multiple Write Regions Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the flag to enable writes on any regions for geo-replicat [...]
+ "preferredRegions": { "kind": "parameter", "displayName": "Preferred Regions", "group": "common", "label": "common", "required": false, "type": "array", "javaType": "java.util.List<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the preferred regions for geo-replicated database accounts. For example, East US [...]
+ "readRequestsFallbackEnabled": { "kind": "parameter", "displayName": "Read Requests Fallback Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets whether to allow for reads to go to multiple regions conf [...]
+ "throughputProperties": { "kind": "parameter", "displayName": "Throughput Properties", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.ThroughputProperties", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets throughput of the resources in the Azure Cosmos DB service." },
+ "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a m [...]
+ "changeFeedProcessorOptions": { "kind": "parameter", "displayName": "Change Feed Processor Options", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.ChangeFeedProcessorOptions", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the ChangeFeedProcessorOptions to b [...]
+ "createLeaseContainerIfNotExists": { "kind": "parameter", "displayName": "Create Lease Container If Not Exists", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos leas [...]
+ "createLeaseDatabaseIfNotExists": { "kind": "parameter", "displayName": "Create Lease Database If Not Exists", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets if the component should create Cosmos lease [...]
+ "hostName": { "kind": "parameter", "displayName": "Host Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the hostname. The host: a host is an application instance that uses the change feed processor to listen for [...]
+ "leaseContainerName": { "kind": "parameter", "displayName": "Lease Container Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "camel-lease", "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the lease container which acts as a state storage and c [...]
+ "leaseDatabaseName": { "kind": "parameter", "displayName": "Lease Database Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the lease database where the leaseContainerName will be stored. If it is not specified, [...]
+ "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, "autowired": 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 con [...]
+ "exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
+ "itemId": { "kind": "parameter", "displayName": "Item Id", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets the itemId in case needed for operation on item like delete, replace" },
+ "itemPartitionKey": { "kind": "parameter", "displayName": "Item Partition Key", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.PartitionKey", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets partition key. Represents a partition key value in the Azure Cosmos DB [...]
+ "lazyStartProducer": { "kind": "parameter", "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 sta [...]
+ "operation": { "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.azure.cosmosdb.CosmosDbOperationsDefinition", "enum": [ "listDatabases", "createDatabase", "queryDatabases", "deleteDatabase", "createContainer", "replaceDatabaseThroughput", "listContainers", "queryContainers", "deleteContainer", "replaceContainerThroughput", "createItem", "upsertItem", "deleteItem", "r [...]
+ "query": { "kind": "parameter", "displayName": "Query", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "An SQL query to execute on a given resources. To learn more about Cosmos SQL API, check this link {link https:\/\/docs. [...]
+ "queryRequestOptions": { "kind": "parameter", "displayName": "Query Request Options", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "com.azure.cosmos.models.CosmosQueryRequestOptions", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Set additional QueryRequestOptions that can be used with [...]
+ "accountKey": { "kind": "parameter", "displayName": "Account Key", "group": "security", "label": "security", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration", "configurationField": "configuration", "description": "Sets either a master or readonly key used to perform authentication for accessing resource." }
+ }
+}
diff --git a/components-starter/README.adoc b/components-starter/README.adoc
index bcd9058..d6c155a 100644
--- a/components-starter/README.adoc
+++ b/components-starter/README.adoc
@@ -93,6 +93,8 @@ Number of Camel components: 329 in 265 JAR artifacts (1 deprecated)
| xref:latest@components::aws-secrets-manager-component.adoc[AWS Secrets Manager] | camel-aws-secrets-manager-starter | Preview | 3.9 | Manage AWS Secrets Manager services using AWS SDK version 2.x.
+| xref:latest@components::azure-cosmosdb-component.adoc[Azure CosmosDB] | camel-azure-cosmosdb-starter | Preview | 3.10 | Azure Cosmos DB is Microsofts globally distributed, multi-model database service for operational and analytics workloads. It offers multi-mastering feature by automatically scaling throughput, compute, and storage. This component interacts with Azure CosmosDB through Azure SQL API
+
| xref:latest@components::azure-eventhubs-component.adoc[Azure Event Hubs] | camel-azure-eventhubs-starter | Stable | 3.5 | The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.
| xref:latest@components::azure-storage-blob-component.adoc[Azure Storage Blob Service] | camel-azure-storage-blob-starter | Stable | 3.3 | Store and retrieve blobs from Azure Storage Blob Service using SDK v12.
diff --git a/components-starter/camel-azure-cosmosdb-starter/pom.xml b/components-starter/camel-azure-cosmosdb-starter/pom.xml
new file mode 100644
index 0000000..2570cfe
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>components-starter</artifactId>
+ <version>3.10.0-SNAPSHOT</version>
+ </parent>
+ <artifactId>camel-azure-cosmosdb-starter</artifactId>
+ <packaging>jar</packaging>
+ <!-- <name>Camel SB Starters :: Name Here</name>-->
+ <dependencies>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter</artifactId>
+ <version>${spring-boot-version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-azure-cosmosdb</artifactId>
+ <version>${camel-version}</version>
+ </dependency>
+ <!--START OF GENERATED CODE-->
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-core-starter</artifactId>
+ </dependency>
+ <!--END OF GENERATED CODE-->
+ </dependencies>
+</project>
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/docs/azure-cosmosdb-starter.adoc b/components-starter/camel-azure-cosmosdb-starter/src/main/docs/azure-cosmosdb-starter.adoc
new file mode 100644
index 0000000..97d8b11
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/docs/azure-cosmosdb-starter.adoc
@@ -0,0 +1,60 @@
+// spring-boot-auto-configure options: START
+:page-partial:
+:doctitle: Camel Spring Boot Starter for azure-cosmosdb
+
+== Spring Boot Auto-Configuration
+
+When using azure-cosmosdb with Spring Boot make sure to use the following Maven dependency to have support for auto configuration:
+
+[source,xml]
+----
+<dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-azure-cosmosdb-starter</artifactId>
+ <version>x.x.x</version>
+ <!-- use the same version as your Camel core version -->
+</dependency>
+----
+
+
+The component supports 30 options, which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *camel.component.azure-cosmosdb.account-key* | Sets either a master or readonly key used to perform authentication for accessing resource. | | String
+| *camel.component.azure-cosmosdb.autowired-enabled* | 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 then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc. | true | Boolean
+| *camel.component.azure-cosmosdb.bridge-error-handler* | 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
+| *camel.component.azure-cosmosdb.change-feed-processor-options* | Sets the ChangeFeedProcessorOptions to be used. Unless specifically set the default values that will be used are: maximum items per page or FeedResponse: 100 lease renew interval: 17 seconds lease acquire interval: 13 seconds lease expiration interval: 60 seconds feed poll delay: 5 seconds maximum scale count: unlimited. The option is a com.azure.cosmos.models.ChangeFeedProcessorOptions type. | | ChangeFeedProcessorOptions
+| *camel.component.azure-cosmosdb.client-telemetry-enabled* | Sets the flag to enable client telemetry which will periodically collect database operations aggregation statistics, system information like cpu/memory and send it to cosmos monitoring service, which will be helpful during debugging. DEFAULT value is false indicating this is opt in feature, by default no telemetry collection. | false | Boolean
+| *camel.component.azure-cosmosdb.configuration* | The component configurations. The option is a org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration type. | | CosmosDbConfiguration
+| *camel.component.azure-cosmosdb.connection-sharing-across-clients-enabled* | Enables connections sharing across multiple Cosmos Clients. The default is false. When you have multiple instances of Cosmos Client in the same JVM interacting to multiple Cosmos accounts, enabling this allows connection sharing in Direct mode if possible between instances of Cosmos Client. Please note, when setting this option, the connection configuration (e.g., socket timeout config, idle timeout config) of [...]
+| *camel.component.azure-cosmosdb.consistency-level* | Sets the consistency levels supported for Azure Cosmos DB client operations in the Azure Cosmos DB service. The requested ConsistencyLevel must match or be weaker than that provisioned for the database account. Consistency levels by order of strength are STRONG, BOUNDED_STALENESS, SESSION and EVENTUAL. Refer to consistency level documentation for additional details: \https://docs.microsoft.com/en-us/azure/cosmos-db/consistency-levels [...]
+| *camel.component.azure-cosmosdb.container-partition-key-path* | Sets the container partition key path. | | String
+| *camel.component.azure-cosmosdb.content-response-on-write-enabled* | Sets the boolean to only return the headers and status code in Cosmos DB response in case of Create, Update and Delete operations on CosmosItem. In Consumer, it is enabled by default because of the ChangeFeed in the consumer that needs this flag to be enabled and thus is shouldn't be overridden. In Producer, it advised to disable it since it reduces the network overhead | true | Boolean
+| *camel.component.azure-cosmosdb.cosmos-async-client* | Inject an external CosmosAsyncClient into the component which provides a client-side logical representation of the Azure Cosmos DB service. This asynchronous client is used to configure and execute requests against the service. The option is a com.azure.cosmos.CosmosAsyncClient type. | | CosmosAsyncClient
+| *camel.component.azure-cosmosdb.create-container-if-not-exists* | Sets if the component should create Cosmos container automatically in case it doesn't exist in Cosmos database | false | Boolean
+| *camel.component.azure-cosmosdb.create-database-if-not-exists* | Sets if the component should create Cosmos database automatically in case it doesn't exist in Cosmos account | false | Boolean
+| *camel.component.azure-cosmosdb.create-lease-container-if-not-exists* | Sets if the component should create Cosmos lease container for the consumer automatically in case it doesn't exist in Cosmos database | false | Boolean
+| *camel.component.azure-cosmosdb.create-lease-database-if-not-exists* | Sets if the component should create Cosmos lease database for the consumer automatically in case it doesn't exist in Cosmos account | false | Boolean
+| *camel.component.azure-cosmosdb.database-endpoint* | Sets the Azure Cosmos database endpoint the component will connect to. | | String
+| *camel.component.azure-cosmosdb.enabled* | Whether to enable auto configuration of the azure-cosmosdb component. This is enabled by default. | | Boolean
+| *camel.component.azure-cosmosdb.host-name* | Sets the hostname. The host: a host is an application instance that uses the change feed processor to listen for changes. Multiple instances with the same lease configuration can run in parallel, but each instance should have a different instance name. If not specified, this will be a generated random hostname. | | String
+| *camel.component.azure-cosmosdb.item-id* | Sets the itemId in case needed for operation on item like delete, replace | | String
+| *camel.component.azure-cosmosdb.item-partition-key* | Sets partition key. Represents a partition key value in the Azure Cosmos DB database service. A partition key identifies the partition where the item is stored in. The option is a com.azure.cosmos.models.PartitionKey type. | | PartitionKey
+| *camel.component.azure-cosmosdb.lazy-start-producer* | 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 proce [...]
+| *camel.component.azure-cosmosdb.lease-container-name* | Sets the lease container which acts as a state storage and coordinates processing the change feed across multiple workers. The lease container can be stored in the same account as the monitored container or in a separate account. It will be auto created if createLeaseContainerIfNotExists is set to true. | camel-lease | String
+| *camel.component.azure-cosmosdb.lease-database-name* | Sets the lease database where the leaseContainerName will be stored. If it is not specified, this component will store the lease container in the same database that is specified in databaseName. It will be auto created if createLeaseDatabaseIfNotExists is set to true. | | String
+| *camel.component.azure-cosmosdb.multiple-write-regions-enabled* | Sets the flag to enable writes on any regions for geo-replicated database accounts in the Azure Cosmos DB service. When the value of this property is true, the SDK will direct write operations to available writable regions of geo-replicated database account. Writable regions are ordered by PreferredRegions property. Setting the property value to true has no effect until EnableMultipleWriteRegions in DatabaseAccount is al [...]
+| *camel.component.azure-cosmosdb.operation* | The CosmosDB operation that can be used with this component on the producer. | | CosmosDbOperationsDefinition
+| *camel.component.azure-cosmosdb.preferred-regions* | Sets the preferred regions for geo-replicated database accounts. For example, East US as the preferred region. When EnableEndpointDiscovery is true and PreferredRegions is non-empty, the SDK will prefer to use the regions in the container in the order they are specified to perform operations. | | List
+| *camel.component.azure-cosmosdb.query* | An SQL query to execute on a given resources. To learn more about Cosmos SQL API, check this link {link \https://docs.microsoft.com/en-us/azure/cosmos-db/sql-query-getting-started} | | String
+| *camel.component.azure-cosmosdb.query-request-options* | Set additional QueryRequestOptions that can be used with queryItems, queryContainers, queryDatabases, listDatabases, listItems, listContainers operations. The option is a com.azure.cosmos.models.CosmosQueryRequestOptions type. | | CosmosQueryRequestOptions
+| *camel.component.azure-cosmosdb.read-requests-fallback-enabled* | Sets whether to allow for reads to go to multiple regions configured on an account of Azure Cosmos DB service. DEFAULT value is true. If this property is not set, the default is true for all Consistency Levels other than Bounded Staleness, The default is false for Bounded Staleness. 1. endpointDiscoveryEnabled is true 2. the Azure Cosmos DB account has more than one region | true | Boolean
+| *camel.component.azure-cosmosdb.throughput-properties* | Sets throughput of the resources in the Azure Cosmos DB service. The option is a com.azure.cosmos.models.ThroughputProperties type. | | ThroughputProperties
+|===
+
+
+// spring-boot-auto-configure options: END
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentAutoConfiguration.java b/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentAutoConfiguration.java
new file mode 100644
index 0000000..9c88342
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentAutoConfiguration.java
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.azure.cosmosdb.springboot;
+
+import javax.annotation.Generated;
+import org.apache.camel.CamelContext;
+import org.apache.camel.Component;
+import org.apache.camel.component.azure.cosmosdb.CosmosDbComponent;
+import org.apache.camel.spi.ComponentCustomizer;
+import org.apache.camel.spring.boot.CamelAutoConfiguration;
+import org.apache.camel.spring.boot.ComponentConfigurationProperties;
+import org.apache.camel.spring.boot.util.CamelPropertiesHelper;
+import org.apache.camel.spring.boot.util.ConditionalOnCamelContextAndAutoConfigurationBeans;
+import org.apache.camel.spring.boot.util.ConditionalOnHierarchicalProperties;
+import org.apache.camel.spring.boot.util.HierarchicalPropertiesEvaluator;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Conditional;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Lazy;
+
+/**
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
+@Configuration(proxyBeanMethods = false)
+@Conditional(ConditionalOnCamelContextAndAutoConfigurationBeans.class)
+@EnableConfigurationProperties({ComponentConfigurationProperties.class,CosmosDbComponentConfiguration.class})
+@ConditionalOnHierarchicalProperties({"camel.component", "camel.component.azure-cosmosdb"})
+@AutoConfigureAfter({CamelAutoConfiguration.class, CosmosDbComponentConverter.class})
+public class CosmosDbComponentAutoConfiguration {
+
+ @Autowired
+ private ApplicationContext applicationContext;
+ private final CamelContext camelContext;
+ @Autowired
+ private CosmosDbComponentConfiguration configuration;
+
+ public CosmosDbComponentAutoConfiguration(
+ org.apache.camel.CamelContext camelContext) {
+ this.camelContext = camelContext;
+ }
+
+ @Lazy
+ @Bean
+ public ComponentCustomizer configureCosmosDbComponent() {
+ return new ComponentCustomizer() {
+ @Override
+ public void configure(String name, Component target) {
+ CamelPropertiesHelper.copyProperties(camelContext, configuration, target);
+ }
+ @Override
+ public boolean isEnabled(String name, Component target) {
+ return HierarchicalPropertiesEvaluator.evaluate(
+ applicationContext,
+ "camel.component.customizer",
+ "camel.component.azure-cosmosdb.customizer")
+ && target instanceof CosmosDbComponent;
+ }
+ };
+ }
+}
\ No newline at end of file
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentConfiguration.java b/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentConfiguration.java
new file mode 100644
index 0000000..870fa03
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentConfiguration.java
@@ -0,0 +1,498 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.azure.cosmosdb.springboot;
+
+import java.util.List;
+import javax.annotation.Generated;
+import com.azure.cosmos.ConsistencyLevel;
+import com.azure.cosmos.CosmosAsyncClient;
+import com.azure.cosmos.models.ChangeFeedProcessorOptions;
+import com.azure.cosmos.models.CosmosQueryRequestOptions;
+import com.azure.cosmos.models.PartitionKey;
+import com.azure.cosmos.models.ThroughputProperties;
+import org.apache.camel.component.azure.cosmosdb.CosmosDbComponent;
+import org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration;
+import org.apache.camel.component.azure.cosmosdb.CosmosDbOperationsDefinition;
+import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * Azure Cosmos DB is Microsofts globally distributed, multi-model database
+ * service for operational and analytics workloads. It offers multi-mastering
+ * feature by automatically scaling throughput, compute, and storage. This
+ * component interacts with Azure CosmosDB through Azure SQL API
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
+@ConfigurationProperties(prefix = "camel.component.azure-cosmosdb")
+public class CosmosDbComponentConfiguration
+ extends
+ ComponentConfigurationPropertiesCommon {
+
+ /**
+ * Whether to enable auto configuration of the azure-cosmosdb component.
+ * This is enabled by default.
+ */
+ private Boolean enabled;
+ /**
+ * Sets the flag to enable client telemetry which will periodically collect
+ * database operations aggregation statistics, system information like
+ * cpu/memory and send it to cosmos monitoring service, which will be
+ * helpful during debugging. DEFAULT value is false indicating this is opt
+ * in feature, by default no telemetry collection.
+ */
+ private Boolean clientTelemetryEnabled = false;
+ /**
+ * The component configurations. The option is a
+ * org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration type.
+ */
+ private CosmosDbConfiguration configuration;
+ /**
+ * Enables connections sharing across multiple Cosmos Clients. The default
+ * is false. When you have multiple instances of Cosmos Client in the same
+ * JVM interacting to multiple Cosmos accounts, enabling this allows
+ * connection sharing in Direct mode if possible between instances of Cosmos
+ * Client. Please note, when setting this option, the connection
+ * configuration (e.g., socket timeout config, idle timeout config) of the
+ * first instantiated client will be used for all other client instances.
+ */
+ private Boolean connectionSharingAcrossClientsEnabled = false;
+ /**
+ * Sets the consistency levels supported for Azure Cosmos DB client
+ * operations in the Azure Cosmos DB service. The requested ConsistencyLevel
+ * must match or be weaker than that provisioned for the database account.
+ * Consistency levels by order of strength are STRONG, BOUNDED_STALENESS,
+ * SESSION and EVENTUAL. Refer to consistency level documentation for
+ * additional details:
+ * https://docs.microsoft.com/en-us/azure/cosmos-db/consistency-levels
+ */
+ private ConsistencyLevel consistencyLevel = ConsistencyLevel.SESSION;
+ /**
+ * Sets the container partition key path.
+ */
+ private String containerPartitionKeyPath;
+ /**
+ * Sets the boolean to only return the headers and status code in Cosmos DB
+ * response in case of Create, Update and Delete operations on CosmosItem.
+ * In Consumer, it is enabled by default because of the ChangeFeed in the
+ * consumer that needs this flag to be enabled and thus is shouldn't be
+ * overridden. In Producer, it advised to disable it since it reduces the
+ * network overhead
+ */
+ private Boolean contentResponseOnWriteEnabled = true;
+ /**
+ * Inject an external CosmosAsyncClient into the component which provides a
+ * client-side logical representation of the Azure Cosmos DB service. This
+ * asynchronous client is used to configure and execute requests against the
+ * service. The option is a com.azure.cosmos.CosmosAsyncClient type.
+ */
+ private CosmosAsyncClient cosmosAsyncClient;
+ /**
+ * Sets if the component should create Cosmos container automatically in
+ * case it doesn't exist in Cosmos database
+ */
+ private Boolean createContainerIfNotExists = false;
+ /**
+ * Sets if the component should create Cosmos database automatically in case
+ * it doesn't exist in Cosmos account
+ */
+ private Boolean createDatabaseIfNotExists = false;
+ /**
+ * Sets the Azure Cosmos database endpoint the component will connect to.
+ */
+ private String databaseEndpoint;
+ /**
+ * Sets the flag to enable writes on any regions for geo-replicated database
+ * accounts in the Azure Cosmos DB service. When the value of this property
+ * is true, the SDK will direct write operations to available writable
+ * regions of geo-replicated database account. Writable regions are ordered
+ * by PreferredRegions property. Setting the property value to true has no
+ * effect until EnableMultipleWriteRegions in DatabaseAccount is also set to
+ * true. DEFAULT value is true indicating that writes are directed to
+ * available writable regions of geo-replicated database account.
+ */
+ private Boolean multipleWriteRegionsEnabled = true;
+ /**
+ * Sets the preferred regions for geo-replicated database accounts. For
+ * example, East US as the preferred region. When EnableEndpointDiscovery is
+ * true and PreferredRegions is non-empty, the SDK will prefer to use the
+ * regions in the container in the order they are specified to perform
+ * operations.
+ */
+ private List<String> preferredRegions;
+ /**
+ * Sets whether to allow for reads to go to multiple regions configured on
+ * an account of Azure Cosmos DB service. DEFAULT value is true. If this
+ * property is not set, the default is true for all Consistency Levels other
+ * than Bounded Staleness, The default is false for Bounded Staleness. 1.
+ * endpointDiscoveryEnabled is true 2. the Azure Cosmos DB account has more
+ * than one region
+ */
+ private Boolean readRequestsFallbackEnabled = true;
+ /**
+ * Sets throughput of the resources in the Azure Cosmos DB service. The
+ * option is a com.azure.cosmos.models.ThroughputProperties type.
+ */
+ private ThroughputProperties throughputProperties;
+ /**
+ * 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.
+ */
+ private Boolean bridgeErrorHandler = false;
+ /**
+ * Sets the ChangeFeedProcessorOptions to be used. Unless specifically set
+ * the default values that will be used are: maximum items per page or
+ * FeedResponse: 100 lease renew interval: 17 seconds lease acquire
+ * interval: 13 seconds lease expiration interval: 60 seconds feed poll
+ * delay: 5 seconds maximum scale count: unlimited. The option is a
+ * com.azure.cosmos.models.ChangeFeedProcessorOptions type.
+ */
+ private ChangeFeedProcessorOptions changeFeedProcessorOptions;
+ /**
+ * Sets if the component should create Cosmos lease container for the
+ * consumer automatically in case it doesn't exist in Cosmos database
+ */
+ private Boolean createLeaseContainerIfNotExists = false;
+ /**
+ * Sets if the component should create Cosmos lease database for the
+ * consumer automatically in case it doesn't exist in Cosmos account
+ */
+ private Boolean createLeaseDatabaseIfNotExists = false;
+ /**
+ * Sets the hostname. The host: a host is an application instance that uses
+ * the change feed processor to listen for changes. Multiple instances with
+ * the same lease configuration can run in parallel, but each instance
+ * should have a different instance name. If not specified, this will be a
+ * generated random hostname.
+ */
+ private String hostName;
+ /**
+ * Sets the lease container which acts as a state storage and coordinates
+ * processing the change feed across multiple workers. The lease container
+ * can be stored in the same account as the monitored container or in a
+ * separate account. It will be auto created if
+ * createLeaseContainerIfNotExists is set to true.
+ */
+ private String leaseContainerName = "camel-lease";
+ /**
+ * Sets the lease database where the leaseContainerName will be stored. If
+ * it is not specified, this component will store the lease container in the
+ * same database that is specified in databaseName. It will be auto created
+ * if createLeaseDatabaseIfNotExists is set to true.
+ */
+ private String leaseDatabaseName;
+ /**
+ * Sets the itemId in case needed for operation on item like delete, replace
+ */
+ private String itemId;
+ /**
+ * Sets partition key. Represents a partition key value in the Azure Cosmos
+ * DB database service. A partition key identifies the partition where the
+ * item is stored in. The option is a com.azure.cosmos.models.PartitionKey
+ * type.
+ */
+ private PartitionKey itemPartitionKey;
+ /**
+ * 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.
+ */
+ private Boolean lazyStartProducer = false;
+ /**
+ * The CosmosDB operation that can be used with this component on the
+ * producer.
+ */
+ private CosmosDbOperationsDefinition operation = CosmosDbOperationsDefinition.listDatabases;
+ /**
+ * An SQL query to execute on a given resources. To learn more about Cosmos
+ * SQL API, check this link {link
+ * https://docs.microsoft.com/en-us/azure/cosmos-db/sql-query-getting-started}
+ */
+ private String query;
+ /**
+ * Set additional QueryRequestOptions that can be used with queryItems,
+ * queryContainers, queryDatabases, listDatabases, listItems, listContainers
+ * operations. The option is a
+ * com.azure.cosmos.models.CosmosQueryRequestOptions type.
+ */
+ private CosmosQueryRequestOptions queryRequestOptions;
+ /**
+ * 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
+ * then gets configured on the component. This can be used for automatic
+ * configuring JDBC data sources, JMS connection factories, AWS Clients,
+ * etc.
+ */
+ private Boolean autowiredEnabled = true;
+ /**
+ * Sets either a master or readonly key used to perform authentication for
+ * accessing resource.
+ */
+ private String accountKey;
+
+ public Boolean getClientTelemetryEnabled() {
+ return clientTelemetryEnabled;
+ }
+
+ public void setClientTelemetryEnabled(Boolean clientTelemetryEnabled) {
+ this.clientTelemetryEnabled = clientTelemetryEnabled;
+ }
+
+ public CosmosDbConfiguration getConfiguration() {
+ return configuration;
+ }
+
+ public void setConfiguration(CosmosDbConfiguration configuration) {
+ this.configuration = configuration;
+ }
+
+ public Boolean getConnectionSharingAcrossClientsEnabled() {
+ return connectionSharingAcrossClientsEnabled;
+ }
+
+ public void setConnectionSharingAcrossClientsEnabled(
+ Boolean connectionSharingAcrossClientsEnabled) {
+ this.connectionSharingAcrossClientsEnabled = connectionSharingAcrossClientsEnabled;
+ }
+
+ public ConsistencyLevel getConsistencyLevel() {
+ return consistencyLevel;
+ }
+
+ public void setConsistencyLevel(ConsistencyLevel consistencyLevel) {
+ this.consistencyLevel = consistencyLevel;
+ }
+
+ public String getContainerPartitionKeyPath() {
+ return containerPartitionKeyPath;
+ }
+
+ public void setContainerPartitionKeyPath(String containerPartitionKeyPath) {
+ this.containerPartitionKeyPath = containerPartitionKeyPath;
+ }
+
+ public Boolean getContentResponseOnWriteEnabled() {
+ return contentResponseOnWriteEnabled;
+ }
+
+ public void setContentResponseOnWriteEnabled(
+ Boolean contentResponseOnWriteEnabled) {
+ this.contentResponseOnWriteEnabled = contentResponseOnWriteEnabled;
+ }
+
+ public CosmosAsyncClient getCosmosAsyncClient() {
+ return cosmosAsyncClient;
+ }
+
+ public void setCosmosAsyncClient(CosmosAsyncClient cosmosAsyncClient) {
+ this.cosmosAsyncClient = cosmosAsyncClient;
+ }
+
+ public Boolean getCreateContainerIfNotExists() {
+ return createContainerIfNotExists;
+ }
+
+ public void setCreateContainerIfNotExists(Boolean createContainerIfNotExists) {
+ this.createContainerIfNotExists = createContainerIfNotExists;
+ }
+
+ public Boolean getCreateDatabaseIfNotExists() {
+ return createDatabaseIfNotExists;
+ }
+
+ public void setCreateDatabaseIfNotExists(Boolean createDatabaseIfNotExists) {
+ this.createDatabaseIfNotExists = createDatabaseIfNotExists;
+ }
+
+ public String getDatabaseEndpoint() {
+ return databaseEndpoint;
+ }
+
+ public void setDatabaseEndpoint(String databaseEndpoint) {
+ this.databaseEndpoint = databaseEndpoint;
+ }
+
+ public Boolean getMultipleWriteRegionsEnabled() {
+ return multipleWriteRegionsEnabled;
+ }
+
+ public void setMultipleWriteRegionsEnabled(
+ Boolean multipleWriteRegionsEnabled) {
+ this.multipleWriteRegionsEnabled = multipleWriteRegionsEnabled;
+ }
+
+ public List<String> getPreferredRegions() {
+ return preferredRegions;
+ }
+
+ public void setPreferredRegions(List<String> preferredRegions) {
+ this.preferredRegions = preferredRegions;
+ }
+
+ public Boolean getReadRequestsFallbackEnabled() {
+ return readRequestsFallbackEnabled;
+ }
+
+ public void setReadRequestsFallbackEnabled(
+ Boolean readRequestsFallbackEnabled) {
+ this.readRequestsFallbackEnabled = readRequestsFallbackEnabled;
+ }
+
+ public ThroughputProperties getThroughputProperties() {
+ return throughputProperties;
+ }
+
+ public void setThroughputProperties(
+ ThroughputProperties throughputProperties) {
+ this.throughputProperties = throughputProperties;
+ }
+
+ public Boolean getBridgeErrorHandler() {
+ return bridgeErrorHandler;
+ }
+
+ public void setBridgeErrorHandler(Boolean bridgeErrorHandler) {
+ this.bridgeErrorHandler = bridgeErrorHandler;
+ }
+
+ public ChangeFeedProcessorOptions getChangeFeedProcessorOptions() {
+ return changeFeedProcessorOptions;
+ }
+
+ public void setChangeFeedProcessorOptions(
+ ChangeFeedProcessorOptions changeFeedProcessorOptions) {
+ this.changeFeedProcessorOptions = changeFeedProcessorOptions;
+ }
+
+ public Boolean getCreateLeaseContainerIfNotExists() {
+ return createLeaseContainerIfNotExists;
+ }
+
+ public void setCreateLeaseContainerIfNotExists(
+ Boolean createLeaseContainerIfNotExists) {
+ this.createLeaseContainerIfNotExists = createLeaseContainerIfNotExists;
+ }
+
+ public Boolean getCreateLeaseDatabaseIfNotExists() {
+ return createLeaseDatabaseIfNotExists;
+ }
+
+ public void setCreateLeaseDatabaseIfNotExists(
+ Boolean createLeaseDatabaseIfNotExists) {
+ this.createLeaseDatabaseIfNotExists = createLeaseDatabaseIfNotExists;
+ }
+
+ public String getHostName() {
+ return hostName;
+ }
+
+ public void setHostName(String hostName) {
+ this.hostName = hostName;
+ }
+
+ public String getLeaseContainerName() {
+ return leaseContainerName;
+ }
+
+ public void setLeaseContainerName(String leaseContainerName) {
+ this.leaseContainerName = leaseContainerName;
+ }
+
+ public String getLeaseDatabaseName() {
+ return leaseDatabaseName;
+ }
+
+ public void setLeaseDatabaseName(String leaseDatabaseName) {
+ this.leaseDatabaseName = leaseDatabaseName;
+ }
+
+ public String getItemId() {
+ return itemId;
+ }
+
+ public void setItemId(String itemId) {
+ this.itemId = itemId;
+ }
+
+ public PartitionKey getItemPartitionKey() {
+ return itemPartitionKey;
+ }
+
+ public void setItemPartitionKey(PartitionKey itemPartitionKey) {
+ this.itemPartitionKey = itemPartitionKey;
+ }
+
+ public Boolean getLazyStartProducer() {
+ return lazyStartProducer;
+ }
+
+ public void setLazyStartProducer(Boolean lazyStartProducer) {
+ this.lazyStartProducer = lazyStartProducer;
+ }
+
+ public CosmosDbOperationsDefinition getOperation() {
+ return operation;
+ }
+
+ public void setOperation(CosmosDbOperationsDefinition operation) {
+ this.operation = operation;
+ }
+
+ public String getQuery() {
+ return query;
+ }
+
+ public void setQuery(String query) {
+ this.query = query;
+ }
+
+ public CosmosQueryRequestOptions getQueryRequestOptions() {
+ return queryRequestOptions;
+ }
+
+ public void setQueryRequestOptions(
+ CosmosQueryRequestOptions queryRequestOptions) {
+ this.queryRequestOptions = queryRequestOptions;
+ }
+
+ public Boolean getAutowiredEnabled() {
+ return autowiredEnabled;
+ }
+
+ public void setAutowiredEnabled(Boolean autowiredEnabled) {
+ this.autowiredEnabled = autowiredEnabled;
+ }
+
+ public String getAccountKey() {
+ return accountKey;
+ }
+
+ public void setAccountKey(String accountKey) {
+ this.accountKey = accountKey;
+ }
+}
\ No newline at end of file
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentConverter.java b/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentConverter.java
new file mode 100644
index 0000000..52e8210
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/java/org/apache/camel/component/azure/cosmosdb/springboot/CosmosDbComponentConverter.java
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.azure.cosmosdb.springboot;
+
+import java.util.LinkedHashSet;
+import java.util.Set;
+import javax.annotation.Generated;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.context.properties.ConfigurationPropertiesBinding;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.convert.TypeDescriptor;
+import org.springframework.core.convert.converter.GenericConverter;
+import org.springframework.stereotype.Component;
+
+/**
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
+@Configuration(proxyBeanMethods = false)
+@ConfigurationPropertiesBinding
+@Component
+public class CosmosDbComponentConverter implements GenericConverter {
+
+ @Autowired
+ private ApplicationContext applicationContext;
+
+ public Set<ConvertiblePair> getConvertibleTypes() {
+ Set<ConvertiblePair> answer = new LinkedHashSet<>();
+ answer.add(new ConvertiblePair(String.class, org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration.class));
+ answer.add(new ConvertiblePair(String.class, com.azure.cosmos.CosmosAsyncClient.class));
+ answer.add(new ConvertiblePair(String.class, com.azure.cosmos.models.ThroughputProperties.class));
+ answer.add(new ConvertiblePair(String.class, com.azure.cosmos.models.ChangeFeedProcessorOptions.class));
+ answer.add(new ConvertiblePair(String.class, com.azure.cosmos.models.PartitionKey.class));
+ answer.add(new ConvertiblePair(String.class, com.azure.cosmos.models.CosmosQueryRequestOptions.class));
+ return answer;
+ }
+
+ public Object convert(
+ Object source,
+ TypeDescriptor sourceType,
+ TypeDescriptor targetType) {
+ if (source == null) {
+ return null;
+ }
+ String ref = source.toString();
+ if (!ref.startsWith("#")) {
+ return null;
+ }
+ ref = ref.startsWith("#bean:") ? ref.substring(6) : ref.substring(1);
+ switch (targetType.getName()) {
+ case "org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration": return applicationContext.getBean(ref, org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration.class);
+ case "com.azure.cosmos.CosmosAsyncClient": return applicationContext.getBean(ref, com.azure.cosmos.CosmosAsyncClient.class);
+ case "com.azure.cosmos.models.ThroughputProperties": return applicationContext.getBean(ref, com.azure.cosmos.models.ThroughputProperties.class);
+ case "com.azure.cosmos.models.ChangeFeedProcessorOptions": return applicationContext.getBean(ref, com.azure.cosmos.models.ChangeFeedProcessorOptions.class);
+ case "com.azure.cosmos.models.PartitionKey": return applicationContext.getBean(ref, com.azure.cosmos.models.PartitionKey.class);
+ case "com.azure.cosmos.models.CosmosQueryRequestOptions": return applicationContext.getBean(ref, com.azure.cosmos.models.CosmosQueryRequestOptions.class);
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/LICENSE.txt b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/LICENSE.txt
new file mode 100644
index 0000000..6b0b127
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/LICENSE.txt
@@ -0,0 +1,203 @@
+
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/NOTICE.txt b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/NOTICE.txt
new file mode 100644
index 0000000..2e215bf
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/NOTICE.txt
@@ -0,0 +1,11 @@
+ =========================================================================
+ == NOTICE file corresponding to the section 4 d of ==
+ == the Apache License, Version 2.0, ==
+ == in this case for the Apache Camel distribution. ==
+ =========================================================================
+
+ This product includes software developed by
+ The Apache Software Foundation (http://www.apache.org/).
+
+ Please read the different LICENSE files present in the licenses directory of
+ this distribution.
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/spring.factories b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 0000000..6aead2e
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,21 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+org.apache.camel.component.azure.cosmosdb.springboot.CosmosDbComponentConverter,\
+org.apache.camel.component.azure.cosmosdb.springboot.CosmosDbComponentAutoConfiguration
+
diff --git a/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/spring.provides b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/spring.provides
new file mode 100644
index 0000000..5697cb5
--- /dev/null
+++ b/components-starter/camel-azure-cosmosdb-starter/src/main/resources/META-INF/spring.provides
@@ -0,0 +1,17 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+provides: camel-azure-cosmosdb
diff --git a/components-starter/pom.xml b/components-starter/pom.xml
index 7207e7c..947ec19 100644
--- a/components-starter/pom.xml
+++ b/components-starter/pom.xml
@@ -147,6 +147,7 @@
<module>camel-aws2-sqs-starter</module>
<module>camel-aws2-sts-starter</module>
<module>camel-aws2-translate-starter</module>
+ <module>camel-azure-cosmosdb-starter</module>
<module>camel-azure-eventhubs-starter</module>
<module>camel-azure-storage-blob-starter</module>
<module>camel-azure-storage-datalake-starter</module>
diff --git a/docs/modules/ROOT/pages/azure-cosmosdb-starter.adoc b/docs/modules/ROOT/pages/azure-cosmosdb-starter.adoc
new file mode 100644
index 0000000..97d8b11
--- /dev/null
+++ b/docs/modules/ROOT/pages/azure-cosmosdb-starter.adoc
@@ -0,0 +1,60 @@
+// spring-boot-auto-configure options: START
+:page-partial:
+:doctitle: Camel Spring Boot Starter for azure-cosmosdb
+
+== Spring Boot Auto-Configuration
+
+When using azure-cosmosdb with Spring Boot make sure to use the following Maven dependency to have support for auto configuration:
+
+[source,xml]
+----
+<dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-azure-cosmosdb-starter</artifactId>
+ <version>x.x.x</version>
+ <!-- use the same version as your Camel core version -->
+</dependency>
+----
+
+
+The component supports 30 options, which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *camel.component.azure-cosmosdb.account-key* | Sets either a master or readonly key used to perform authentication for accessing resource. | | String
+| *camel.component.azure-cosmosdb.autowired-enabled* | 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 then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc. | true | Boolean
+| *camel.component.azure-cosmosdb.bridge-error-handler* | 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
+| *camel.component.azure-cosmosdb.change-feed-processor-options* | Sets the ChangeFeedProcessorOptions to be used. Unless specifically set the default values that will be used are: maximum items per page or FeedResponse: 100 lease renew interval: 17 seconds lease acquire interval: 13 seconds lease expiration interval: 60 seconds feed poll delay: 5 seconds maximum scale count: unlimited. The option is a com.azure.cosmos.models.ChangeFeedProcessorOptions type. | | ChangeFeedProcessorOptions
+| *camel.component.azure-cosmosdb.client-telemetry-enabled* | Sets the flag to enable client telemetry which will periodically collect database operations aggregation statistics, system information like cpu/memory and send it to cosmos monitoring service, which will be helpful during debugging. DEFAULT value is false indicating this is opt in feature, by default no telemetry collection. | false | Boolean
+| *camel.component.azure-cosmosdb.configuration* | The component configurations. The option is a org.apache.camel.component.azure.cosmosdb.CosmosDbConfiguration type. | | CosmosDbConfiguration
+| *camel.component.azure-cosmosdb.connection-sharing-across-clients-enabled* | Enables connections sharing across multiple Cosmos Clients. The default is false. When you have multiple instances of Cosmos Client in the same JVM interacting to multiple Cosmos accounts, enabling this allows connection sharing in Direct mode if possible between instances of Cosmos Client. Please note, when setting this option, the connection configuration (e.g., socket timeout config, idle timeout config) of [...]
+| *camel.component.azure-cosmosdb.consistency-level* | Sets the consistency levels supported for Azure Cosmos DB client operations in the Azure Cosmos DB service. The requested ConsistencyLevel must match or be weaker than that provisioned for the database account. Consistency levels by order of strength are STRONG, BOUNDED_STALENESS, SESSION and EVENTUAL. Refer to consistency level documentation for additional details: \https://docs.microsoft.com/en-us/azure/cosmos-db/consistency-levels [...]
+| *camel.component.azure-cosmosdb.container-partition-key-path* | Sets the container partition key path. | | String
+| *camel.component.azure-cosmosdb.content-response-on-write-enabled* | Sets the boolean to only return the headers and status code in Cosmos DB response in case of Create, Update and Delete operations on CosmosItem. In Consumer, it is enabled by default because of the ChangeFeed in the consumer that needs this flag to be enabled and thus is shouldn't be overridden. In Producer, it advised to disable it since it reduces the network overhead | true | Boolean
+| *camel.component.azure-cosmosdb.cosmos-async-client* | Inject an external CosmosAsyncClient into the component which provides a client-side logical representation of the Azure Cosmos DB service. This asynchronous client is used to configure and execute requests against the service. The option is a com.azure.cosmos.CosmosAsyncClient type. | | CosmosAsyncClient
+| *camel.component.azure-cosmosdb.create-container-if-not-exists* | Sets if the component should create Cosmos container automatically in case it doesn't exist in Cosmos database | false | Boolean
+| *camel.component.azure-cosmosdb.create-database-if-not-exists* | Sets if the component should create Cosmos database automatically in case it doesn't exist in Cosmos account | false | Boolean
+| *camel.component.azure-cosmosdb.create-lease-container-if-not-exists* | Sets if the component should create Cosmos lease container for the consumer automatically in case it doesn't exist in Cosmos database | false | Boolean
+| *camel.component.azure-cosmosdb.create-lease-database-if-not-exists* | Sets if the component should create Cosmos lease database for the consumer automatically in case it doesn't exist in Cosmos account | false | Boolean
+| *camel.component.azure-cosmosdb.database-endpoint* | Sets the Azure Cosmos database endpoint the component will connect to. | | String
+| *camel.component.azure-cosmosdb.enabled* | Whether to enable auto configuration of the azure-cosmosdb component. This is enabled by default. | | Boolean
+| *camel.component.azure-cosmosdb.host-name* | Sets the hostname. The host: a host is an application instance that uses the change feed processor to listen for changes. Multiple instances with the same lease configuration can run in parallel, but each instance should have a different instance name. If not specified, this will be a generated random hostname. | | String
+| *camel.component.azure-cosmosdb.item-id* | Sets the itemId in case needed for operation on item like delete, replace | | String
+| *camel.component.azure-cosmosdb.item-partition-key* | Sets partition key. Represents a partition key value in the Azure Cosmos DB database service. A partition key identifies the partition where the item is stored in. The option is a com.azure.cosmos.models.PartitionKey type. | | PartitionKey
+| *camel.component.azure-cosmosdb.lazy-start-producer* | 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 proce [...]
+| *camel.component.azure-cosmosdb.lease-container-name* | Sets the lease container which acts as a state storage and coordinates processing the change feed across multiple workers. The lease container can be stored in the same account as the monitored container or in a separate account. It will be auto created if createLeaseContainerIfNotExists is set to true. | camel-lease | String
+| *camel.component.azure-cosmosdb.lease-database-name* | Sets the lease database where the leaseContainerName will be stored. If it is not specified, this component will store the lease container in the same database that is specified in databaseName. It will be auto created if createLeaseDatabaseIfNotExists is set to true. | | String
+| *camel.component.azure-cosmosdb.multiple-write-regions-enabled* | Sets the flag to enable writes on any regions for geo-replicated database accounts in the Azure Cosmos DB service. When the value of this property is true, the SDK will direct write operations to available writable regions of geo-replicated database account. Writable regions are ordered by PreferredRegions property. Setting the property value to true has no effect until EnableMultipleWriteRegions in DatabaseAccount is al [...]
+| *camel.component.azure-cosmosdb.operation* | The CosmosDB operation that can be used with this component on the producer. | | CosmosDbOperationsDefinition
+| *camel.component.azure-cosmosdb.preferred-regions* | Sets the preferred regions for geo-replicated database accounts. For example, East US as the preferred region. When EnableEndpointDiscovery is true and PreferredRegions is non-empty, the SDK will prefer to use the regions in the container in the order they are specified to perform operations. | | List
+| *camel.component.azure-cosmosdb.query* | An SQL query to execute on a given resources. To learn more about Cosmos SQL API, check this link {link \https://docs.microsoft.com/en-us/azure/cosmos-db/sql-query-getting-started} | | String
+| *camel.component.azure-cosmosdb.query-request-options* | Set additional QueryRequestOptions that can be used with queryItems, queryContainers, queryDatabases, listDatabases, listItems, listContainers operations. The option is a com.azure.cosmos.models.CosmosQueryRequestOptions type. | | CosmosQueryRequestOptions
+| *camel.component.azure-cosmosdb.read-requests-fallback-enabled* | Sets whether to allow for reads to go to multiple regions configured on an account of Azure Cosmos DB service. DEFAULT value is true. If this property is not set, the default is true for all Consistency Levels other than Bounded Staleness, The default is false for Bounded Staleness. 1. endpointDiscoveryEnabled is true 2. the Azure Cosmos DB account has more than one region | true | Boolean
+| *camel.component.azure-cosmosdb.throughput-properties* | Sets throughput of the resources in the Azure Cosmos DB service. The option is a com.azure.cosmos.models.ThroughputProperties type. | | ThroughputProperties
+|===
+
+
+// spring-boot-auto-configure options: END
diff --git a/docs/modules/ROOT/pages/list.adoc b/docs/modules/ROOT/pages/list.adoc
index bcd9058..d6c155a 100644
--- a/docs/modules/ROOT/pages/list.adoc
+++ b/docs/modules/ROOT/pages/list.adoc
@@ -93,6 +93,8 @@ Number of Camel components: 329 in 265 JAR artifacts (1 deprecated)
| xref:latest@components::aws-secrets-manager-component.adoc[AWS Secrets Manager] | camel-aws-secrets-manager-starter | Preview | 3.9 | Manage AWS Secrets Manager services using AWS SDK version 2.x.
+| xref:latest@components::azure-cosmosdb-component.adoc[Azure CosmosDB] | camel-azure-cosmosdb-starter | Preview | 3.10 | Azure Cosmos DB is Microsofts globally distributed, multi-model database service for operational and analytics workloads. It offers multi-mastering feature by automatically scaling throughput, compute, and storage. This component interacts with Azure CosmosDB through Azure SQL API
+
| xref:latest@components::azure-eventhubs-component.adoc[Azure Event Hubs] | camel-azure-eventhubs-starter | Stable | 3.5 | The azure-eventhubs component that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.
| xref:latest@components::azure-storage-blob-component.adoc[Azure Storage Blob Service] | camel-azure-storage-blob-starter | Stable | 3.3 | Store and retrieve blobs from Azure Storage Blob Service using SDK v12.
diff --git a/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAzureCosmosdbTest.java b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAzureCosmosdbTest.java
new file mode 100644
index 0000000..5733049
--- /dev/null
+++ b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAzureCosmosdbTest.java
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.itest.springboot;
+
+import org.apache.camel.itest.springboot.util.ArquillianPackager;
+import org.jboss.arquillian.container.test.api.Deployment;
+import org.jboss.arquillian.junit.Arquillian;
+import org.jboss.shrinkwrap.api.Archive;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+@RunWith(Arquillian.class)
+public class CamelAzureCosmosdbTest extends AbstractSpringBootTestSupport {
+
+ @Deployment
+ public static Archive<?> createSpringBootPackage() throws Exception {
+ return ArquillianPackager.springBootPackage(createTestConfig());
+ }
+
+ public static ITestConfig createTestConfig() {
+ return new ITestConfigBuilder()
+ .module(inferModuleName(CamelAzureCosmosdbTest.class))
+ .build();
+ }
+
+ @Test
+ public void componentTests() throws Exception {
+ this.runComponentTest(config);
+ this.runModuleUnitTestsIfEnabled(config);
+ }
+
+
+}
diff --git a/tooling/camel-spring-boot-bom/pom.xml b/tooling/camel-spring-boot-bom/pom.xml
index 2afb3e7..6e4336c 100644
--- a/tooling/camel-spring-boot-bom/pom.xml
+++ b/tooling/camel-spring-boot-bom/pom.xml
@@ -225,6 +225,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-azure-cosmosdb-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-azure-eventhubs-starter</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml b/tooling/camel-spring-boot-dependencies/pom.xml
index 0a7e8ed..1c3b1d7 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -598,6 +598,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-azure-cosmosdb-starter</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-azure-eventhubs-starter</artifactId>
<version>${project.version}</version>
</dependency>