This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a commit to branch CAMEL-15655
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
commit ce9c9efb072f799abc47d82aebe29e943fb55b16
Author: Omar Al-Safi <omars...@gmail.com>
AuthorDate: Tue May 4 10:19:57 2021 +0200
CAMEL-15655: Add Camel Azure CosmosDB Starter
---
.../camel/springboot/catalog/components.properties | 1 +
.../catalog/components/azure-cosmosdb.json | 88 ++++
.../springboot/catalog/components/coap+tcp.json | 22 +-
.../camel/springboot/catalog/components/coap.json | 22 +-
.../springboot/catalog/components/coaps+tcp.json | 22 +-
.../camel/springboot/catalog/components/coaps.json | 22 +-
.../camel/springboot/catalog/components/sftp.json | 1 +
components-starter/README.adoc | 4 +-
.../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 +
docs/modules/ROOT/pages/list.adoc | 4 +-
.../itest/springboot/CamelAzureCosmosdbTest.java | 47 ++
tooling/camel-spring-boot-bom/pom.xml | 5 +
tooling/camel-spring-boot-dependencies/pom.xml | 12 +-
22 files changed, 1216 insertions(+), 47 deletions(-)
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 ee39b57..8090c23 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/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap+tcp.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap+tcp.json
index 92d9261..c3be65c 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap+tcp.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap+tcp.json
@@ -29,19 +29,19 @@
},
"properties": {
"uri": { "kind": "path", "displayName": "Uri", "group": "common", "label":
"", "required": false, "type": "string", "javaType": "java.net.URI",
"deprecated": false, "autowired": false, "secret": false, "description": "The
URI for the CoAP endpoint" },
- "alias": { "kind": "parameter", "displayName": "Alias", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the alias used to query the KeyStore for the private key
and certificate. This parameter is used when we are enabling TLS with
certificates on the service side, and similarly on the client side when TLS is
used with certificates and client authenticati [...]
- "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
- "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Sets the configuration options for
server-side client-authentication requirements. The value must be one of NONE,
WANT, REQUIRE. If this value is not specified, then it falls back to checking
the sslContextParameters.getServer [...]
- "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": false, "description": "Set the configured private key for use
with Raw Public Key." },
- "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.eclipse.californium.scandium.dtls.pskstore.PskStore", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the PskStore to use
for pre-shared key." },
- "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"java.security.PublicKey", "deprecated": false, "autowired": false, "secret":
false, "description": "Set the configured public key for use with Raw Public
Key." },
- "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "common", "label": "", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description": "The
CBC cipher suites are not recommended. If you want to use them, you first need
to set the recommendedCipherSuitesOnly option to false." },
- "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the SSLContextParameters object for setting up TLS. This is required for
coapstcp, and for coaps when we are using certificates for TLS (as opposed to
RPK or PKS)." },
- "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the TrustedRpkStore to use to determine trust in raw public keys." },
"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 [...]
- "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Comma separated list of methods that
the CoAP consumer will bind to. The default is to bind to all methods (DELETE,
GET, POST, PUT)." },
+ "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "DELETE", "GET", "POST",
"PUT" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Comma separated list of methods that the CoAP consumer will
bind to. The default is to bind to all methods (DELETE, GET, POST, PUT)." },
"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." },
- "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 [...]
+ "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 [...]
+ "alias": { "kind": "parameter", "displayName": "Alias", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "NONE", "WANT", "REQUIRE" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the alias used to query the KeyStore for the private key and certificate. This
parameter is used when we are enabling TLS with certificates on the service
side, and similarly on the client side when TLS [...]
+ "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
+ "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Sets the configuration
options for server-side client-authentication requirements. The value must be
one of NONE, WANT, REQUIRE. If this value is not specified, then it falls back
to checking the sslContextParameters [...]
+ "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": true, "description": "Set the configured private key for use
with Raw Public Key." },
+ "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.pskstore.PskStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the PskStore to use for pre-shared key." },
+ "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PublicKey", "deprecated": false, "autowired": false,
"secret": false, "description": "Set the configured public key for use with Raw
Public Key." },
+ "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "security", "label": "security",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "The CBC cipher suites are not recommended. If you want to use
them, you first need to set the recommendedCipherSuitesOnly option to false." },
+ "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "security", "label": "security", "required": false,
"type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the
SSLContextParameters object for setting up TLS. This is required for coapstcp,
and for coaps when we are using certificates for TLS (as opposed to RPK or
PKS)." },
+ "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "security", "label": "security", "required": false, "type":
"object", "javaType":
"org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore", "deprecated":
false, "autowired": false, "secret": false, "description": "Set the
TrustedRpkStore to use to determine trust in raw public keys." }
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap.json
index fc47497..c505ec9 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coap.json
@@ -29,19 +29,19 @@
},
"properties": {
"uri": { "kind": "path", "displayName": "Uri", "group": "common", "label":
"", "required": false, "type": "string", "javaType": "java.net.URI",
"deprecated": false, "autowired": false, "secret": false, "description": "The
URI for the CoAP endpoint" },
- "alias": { "kind": "parameter", "displayName": "Alias", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the alias used to query the KeyStore for the private key
and certificate. This parameter is used when we are enabling TLS with
certificates on the service side, and similarly on the client side when TLS is
used with certificates and client authenticati [...]
- "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
- "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Sets the configuration options for
server-side client-authentication requirements. The value must be one of NONE,
WANT, REQUIRE. If this value is not specified, then it falls back to checking
the sslContextParameters.getServer [...]
- "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": false, "description": "Set the configured private key for use
with Raw Public Key." },
- "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.eclipse.californium.scandium.dtls.pskstore.PskStore", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the PskStore to use
for pre-shared key." },
- "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"java.security.PublicKey", "deprecated": false, "autowired": false, "secret":
false, "description": "Set the configured public key for use with Raw Public
Key." },
- "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "common", "label": "", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description": "The
CBC cipher suites are not recommended. If you want to use them, you first need
to set the recommendedCipherSuitesOnly option to false." },
- "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the SSLContextParameters object for setting up TLS. This is required for
coapstcp, and for coaps when we are using certificates for TLS (as opposed to
RPK or PKS)." },
- "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the TrustedRpkStore to use to determine trust in raw public keys." },
"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 [...]
- "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Comma separated list of methods that
the CoAP consumer will bind to. The default is to bind to all methods (DELETE,
GET, POST, PUT)." },
+ "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "DELETE", "GET", "POST",
"PUT" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Comma separated list of methods that the CoAP consumer will
bind to. The default is to bind to all methods (DELETE, GET, POST, PUT)." },
"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." },
- "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 [...]
+ "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 [...]
+ "alias": { "kind": "parameter", "displayName": "Alias", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "NONE", "WANT", "REQUIRE" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the alias used to query the KeyStore for the private key and certificate. This
parameter is used when we are enabling TLS with certificates on the service
side, and similarly on the client side when TLS [...]
+ "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
+ "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Sets the configuration
options for server-side client-authentication requirements. The value must be
one of NONE, WANT, REQUIRE. If this value is not specified, then it falls back
to checking the sslContextParameters [...]
+ "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": true, "description": "Set the configured private key for use
with Raw Public Key." },
+ "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.pskstore.PskStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the PskStore to use for pre-shared key." },
+ "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PublicKey", "deprecated": false, "autowired": false,
"secret": false, "description": "Set the configured public key for use with Raw
Public Key." },
+ "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "security", "label": "security",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "The CBC cipher suites are not recommended. If you want to use
them, you first need to set the recommendedCipherSuitesOnly option to false." },
+ "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "security", "label": "security", "required": false,
"type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the
SSLContextParameters object for setting up TLS. This is required for coapstcp,
and for coaps when we are using certificates for TLS (as opposed to RPK or
PKS)." },
+ "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "security", "label": "security", "required": false, "type":
"object", "javaType":
"org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore", "deprecated":
false, "autowired": false, "secret": false, "description": "Set the
TrustedRpkStore to use to determine trust in raw public keys." }
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps+tcp.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps+tcp.json
index 67ac326..771fe9f 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps+tcp.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps+tcp.json
@@ -29,19 +29,19 @@
},
"properties": {
"uri": { "kind": "path", "displayName": "Uri", "group": "common", "label":
"", "required": false, "type": "string", "javaType": "java.net.URI",
"deprecated": false, "autowired": false, "secret": false, "description": "The
URI for the CoAP endpoint" },
- "alias": { "kind": "parameter", "displayName": "Alias", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the alias used to query the KeyStore for the private key
and certificate. This parameter is used when we are enabling TLS with
certificates on the service side, and similarly on the client side when TLS is
used with certificates and client authenticati [...]
- "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
- "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Sets the configuration options for
server-side client-authentication requirements. The value must be one of NONE,
WANT, REQUIRE. If this value is not specified, then it falls back to checking
the sslContextParameters.getServer [...]
- "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": false, "description": "Set the configured private key for use
with Raw Public Key." },
- "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.eclipse.californium.scandium.dtls.pskstore.PskStore", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the PskStore to use
for pre-shared key." },
- "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"java.security.PublicKey", "deprecated": false, "autowired": false, "secret":
false, "description": "Set the configured public key for use with Raw Public
Key." },
- "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "common", "label": "", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description": "The
CBC cipher suites are not recommended. If you want to use them, you first need
to set the recommendedCipherSuitesOnly option to false." },
- "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the SSLContextParameters object for setting up TLS. This is required for
coapstcp, and for coaps when we are using certificates for TLS (as opposed to
RPK or PKS)." },
- "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the TrustedRpkStore to use to determine trust in raw public keys." },
"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 [...]
- "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Comma separated list of methods that
the CoAP consumer will bind to. The default is to bind to all methods (DELETE,
GET, POST, PUT)." },
+ "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "DELETE", "GET", "POST",
"PUT" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Comma separated list of methods that the CoAP consumer will
bind to. The default is to bind to all methods (DELETE, GET, POST, PUT)." },
"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." },
- "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 [...]
+ "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 [...]
+ "alias": { "kind": "parameter", "displayName": "Alias", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "NONE", "WANT", "REQUIRE" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the alias used to query the KeyStore for the private key and certificate. This
parameter is used when we are enabling TLS with certificates on the service
side, and similarly on the client side when TLS [...]
+ "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
+ "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Sets the configuration
options for server-side client-authentication requirements. The value must be
one of NONE, WANT, REQUIRE. If this value is not specified, then it falls back
to checking the sslContextParameters [...]
+ "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": true, "description": "Set the configured private key for use
with Raw Public Key." },
+ "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.pskstore.PskStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the PskStore to use for pre-shared key." },
+ "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PublicKey", "deprecated": false, "autowired": false,
"secret": false, "description": "Set the configured public key for use with Raw
Public Key." },
+ "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "security", "label": "security",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "The CBC cipher suites are not recommended. If you want to use
them, you first need to set the recommendedCipherSuitesOnly option to false." },
+ "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "security", "label": "security", "required": false,
"type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the
SSLContextParameters object for setting up TLS. This is required for coapstcp,
and for coaps when we are using certificates for TLS (as opposed to RPK or
PKS)." },
+ "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "security", "label": "security", "required": false, "type":
"object", "javaType":
"org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore", "deprecated":
false, "autowired": false, "secret": false, "description": "Set the
TrustedRpkStore to use to determine trust in raw public keys." }
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps.json
index d7a2af9..f4ca92e 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/coaps.json
@@ -29,19 +29,19 @@
},
"properties": {
"uri": { "kind": "path", "displayName": "Uri", "group": "common", "label":
"", "required": false, "type": "string", "javaType": "java.net.URI",
"deprecated": false, "autowired": false, "secret": false, "description": "The
URI for the CoAP endpoint" },
- "alias": { "kind": "parameter", "displayName": "Alias", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the alias used to query the KeyStore for the private key
and certificate. This parameter is used when we are enabling TLS with
certificates on the service side, and similarly on the client side when TLS is
used with certificates and client authenticati [...]
- "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
- "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Sets the configuration options for
server-side client-authentication requirements. The value must be one of NONE,
WANT, REQUIRE. If this value is not specified, then it falls back to checking
the sslContextParameters.getServer [...]
- "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": false, "description": "Set the configured private key for use
with Raw Public Key." },
- "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"org.eclipse.californium.scandium.dtls.pskstore.PskStore", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the PskStore to use
for pre-shared key." },
- "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"java.security.PublicKey", "deprecated": false, "autowired": false, "secret":
false, "description": "Set the configured public key for use with Raw Public
Key." },
- "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "common", "label": "", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description": "The
CBC cipher suites are not recommended. If you want to use them, you first need
to set the recommendedCipherSuitesOnly option to false." },
- "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.support.jsse.SSLContextParameters",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the SSLContextParameters object for setting up TLS. This is required for
coapstcp, and for coaps when we are using certificates for TLS (as opposed to
RPK or PKS)." },
- "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the TrustedRpkStore to use to determine trust in raw public keys." },
"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 [...]
- "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "Comma separated list of methods that
the CoAP consumer will bind to. The default is to bind to all methods (DELETE,
GET, POST, PUT)." },
+ "coapMethodRestrict": { "kind": "parameter", "displayName": "Coap Method
Restrict", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "DELETE", "GET", "POST",
"PUT" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Comma separated list of methods that the CoAP consumer will
bind to. The default is to bind to all methods (DELETE, GET, POST, PUT)." },
"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." },
- "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 [...]
+ "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 [...]
+ "alias": { "kind": "parameter", "displayName": "Alias", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "NONE", "WANT", "REQUIRE" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the alias used to query the KeyStore for the private key and certificate. This
parameter is used when we are enabling TLS with certificates on the service
side, and similarly on the client side when TLS [...]
+ "cipherSuites": { "kind": "parameter", "displayName": "Cipher Suites",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the cipherSuites String. This is a comma
separated String of ciphersuites to configure. If it is not specified, then it
falls back to getting the ciphersuites from the sslContextParameters object." },
+ "clientAuthentication": { "kind": "parameter", "displayName": "Client
Authentication", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Sets the configuration
options for server-side client-authentication requirements. The value must be
one of NONE, WANT, REQUIRE. If this value is not specified, then it falls back
to checking the sslContextParameters [...]
+ "privateKey": { "kind": "parameter", "displayName": "Private Key",
"group": "security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PrivateKey", "deprecated": false, "autowired":
false, "secret": true, "description": "Set the configured private key for use
with Raw Public Key." },
+ "pskStore": { "kind": "parameter", "displayName": "Psk Store", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "org.eclipse.californium.scandium.dtls.pskstore.PskStore",
"deprecated": false, "autowired": false, "secret": false, "description": "Set
the PskStore to use for pre-shared key." },
+ "publicKey": { "kind": "parameter", "displayName": "Public Key", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.PublicKey", "deprecated": false, "autowired": false,
"secret": false, "description": "Set the configured public key for use with Raw
Public Key." },
+ "recommendedCipherSuitesOnly": { "kind": "parameter", "displayName":
"Recommended Cipher Suites Only", "group": "security", "label": "security",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "The CBC cipher suites are not recommended. If you want to use
them, you first need to set the recommendedCipherSuitesOnly option to false." },
+ "sslContextParameters": { "kind": "parameter", "displayName": "Ssl Context
Parameters", "group": "security", "label": "security", "required": false,
"type": "object", "javaType":
"org.apache.camel.support.jsse.SSLContextParameters", "deprecated": false,
"autowired": false, "secret": false, "description": "Set the
SSLContextParameters object for setting up TLS. This is required for coapstcp,
and for coaps when we are using certificates for TLS (as opposed to RPK or
PKS)." },
+ "trustedRpkStore": { "kind": "parameter", "displayName": "Trusted Rpk
Store", "group": "security", "label": "security", "required": false, "type":
"object", "javaType":
"org.eclipse.californium.scandium.dtls.rpkstore.TrustedRpkStore", "deprecated":
false, "autowired": false, "secret": false, "description": "Set the
TrustedRpkStore to use to determine trust in raw public keys." }
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
index 1e15141..8d1e164 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/sftp.json
@@ -137,6 +137,7 @@
"timeUnit": { "kind": "parameter", "displayName": "Time Unit", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"object", "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS",
"MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"MILLISECONDS", "description": "Time unit for initialDelay and delay options."
},
"useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Controls if fixed delay
or fixed rate is used. See ScheduledExecutorService in JDK for details." },
"ciphers": { "kind": "parameter", "displayName": "Ciphers", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.file.remote.SftpConfiguration",
"configurationField": "configuration", "description": "Set a comma separated
list of ciphers that will be used in order of preference. Possible cipher names
are defined by JCraf [...]
+ "keyExchangeProtocols": { "kind": "parameter", "displayName": "Key
Exchange Protocols", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.file.remote.SftpConfiguration",
"configurationField": "configuration", "description": "Set a comma separated
list of key exchange protocols that will be used in order of preference. [...]
"keyPair": { "kind": "parameter", "displayName": "Key Pair", "group":
"security", "label": "security", "required": false, "type": "object",
"javaType": "java.security.KeyPair", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.file.remote.SftpConfiguration",
"configurationField": "configuration", "description": "Sets a key pair of the
public and private key so to that the SFTP endpoint can do public\/private key
verification." },
"knownHosts": { "kind": "parameter", "displayName": "Known Hosts",
"group": "security", "label": "security", "required": false, "type": "string",
"javaType": "byte[]", "deprecated": false, "autowired": false, "secret": true,
"configurationClass":
"org.apache.camel.component.file.remote.SftpConfiguration",
"configurationField": "configuration", "description": "Sets the known_hosts
from the byte array, so that the SFTP endpoint can do host key verification." },
"knownHostsFile": { "kind": "parameter", "displayName": "Known Hosts
File", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.file.remote.SftpConfiguration",
"configurationField": "configuration", "description": "Sets the known_hosts
file, so that the SFTP endpoint can do host key verification." },
diff --git a/components-starter/README.adoc b/components-starter/README.adoc
index db9a7dc..a07e8ac 100644
--- a/components-starter/README.adoc
+++ b/components-starter/README.adoc
@@ -5,7 +5,7 @@ Apache Camel Spring Boot supports the following Camel artifacts
as Spring Boot S
== Camel Components
// components: START
-Number of Camel components: 328 in 264 JAR artifacts (1 deprecated)
+Number of Camel components: 329 in 265 JAR artifacts (1 deprecated)
[width="100%",cols="4,3,3,3,6",options="header"]
|===
@@ -93,6 +93,8 @@ Number of Camel components: 328 in 264 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 594e8f0..76b7d24 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/list.adoc
b/docs/modules/ROOT/pages/list.adoc
index db9a7dc..a07e8ac 100644
--- a/docs/modules/ROOT/pages/list.adoc
+++ b/docs/modules/ROOT/pages/list.adoc
@@ -5,7 +5,7 @@ Apache Camel Spring Boot supports the following Camel artifacts
as Spring Boot S
== Camel Components
// components: START
-Number of Camel components: 328 in 264 JAR artifacts (1 deprecated)
+Number of Camel components: 329 in 265 JAR artifacts (1 deprecated)
[width="100%",cols="4,3,3,3,6",options="header"]
|===
@@ -93,6 +93,8 @@ Number of Camel components: 328 in 264 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 ed5639b..da69499 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 c7fc1a9..382a69c 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -248,7 +248,7 @@
<dependency>
<groupId>com.lmax</groupId>
<artifactId>disruptor</artifactId>
- <version>3.4.3</version>
+ <version>3.4.4</version>
</dependency>
<dependency>
<groupId>com.microsoft.azure</groupId>
@@ -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>
@@ -2344,6 +2349,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-azure-cosmosdb</artifactId>
+ <version>3.10.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-azure-eventhubs</artifactId>
<version>3.10.0-SNAPSHOT</version>
</dependency>
