This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 123445d373a Regen
123445d373a is described below
commit 123445d373a5dd050d52a301ae749f1b30f4f1ff
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Sep 9 19:45:08 2022 +0200
Regen
---
.../catalog/components/azure-eventhubs.json | 42 +++++++++++-----------
.../springboot/catalog/components/netty-http.json | 2 ++
.../src/main/docs/azure-eventhubs.json | 20 +++++++----
.../EventHubsComponentConfiguration.java | 32 ++++++++++++-----
.../springboot/EventHubsComponentConverter.java | 2 ++
5 files changed, 63 insertions(+), 35 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
index 9a65a3cc876..cf830c2ec31 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
@@ -25,15 +25,15 @@
"amqpRetryOptions": { "kind": "property", "displayName": "Amqp Retry
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.AmqpRetryOptions", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the retry policy
for EventHubAsyncClient. If not specified, the default r [...]
"amqpTransportType": { "kind": "property", "displayName": "Amqp Transport
Type", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.AmqpTransportType", "enum": [
"Amqp", "AmqpWebSockets" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AMQP", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the tran [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
- "blobAccessKey": { "kind": "property", "displayName": "Blob Access Key",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets access key for the associated azure acco
[...]
+ "blobAccessKey": { "kind": "property", "displayName": "Blob Access Key",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets access key for the associated azure acco
[...]
"blobAccountName": { "kind": "property", "displayName": "Blob Account
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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets Azure account name to be used for a [...]
- "blobContainerName": { "kind": "property", "displayName": "Blob Container
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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets the blob container that shall b [...]
- "blobStorageSharedKeyCredential": { "kind": "property", "displayName":
"Blob Storage Shared Key Credential", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.storage.common.StorageSharedKeyCredential", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default [...]
+ "blobContainerName": { "kind": "property", "displayName": "Blob Container
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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets the blob container that shall b [...]
+ "blobStorageSharedKeyCredential": { "kind": "property", "displayName":
"Blob Storage Shared Key Credential", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.storage.common.StorageSharedKeyCredential", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default [...]
"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 [...]
- "checkpointBatchSize": { "kind": "property", "displayName": "Checkpoint
Batch Size", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch size
between each checkpoint updates. Works jointly with checkpo [...]
- "checkpointBatchTimeout": { "kind": "property", "displayName": "Checkpoint
Batch Timeout", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 5000, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch timeout
between each checkpoint updates. Works jointly wi [...]
- "checkpointStore": { "kind": "property", "displayName": "Checkpoint
Store", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.eventhubs.CheckpointStore",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"BlobCheckpointStore", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the CheckpointStore
the [...]
- "consumerGroupName": { "kind": "property", "displayName": "Consumer Group
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "$Default", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
consumer group this consumer is associated [...]
+ "checkpointBatchSize": { "kind": "property", "displayName": "Checkpoint
Batch Size", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch size
between each checkpoint updates. Works jointly with checkpo [...]
+ "checkpointBatchTimeout": { "kind": "property", "displayName": "Checkpoint
Batch Timeout", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 5000, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch timeout
between each checkpoint updates. Works jointly wi [...]
+ "checkpointStore": { "kind": "property", "displayName": "Checkpoint
Store", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.eventhubs.CheckpointStore",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"BlobCheckpointStore", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the CheckpointStore
the [...]
+ "consumerGroupName": { "kind": "property", "displayName": "Consumer Group
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "$Default", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
consumer group this consumer is associated [...]
"eventPosition": { "kind": "property", "displayName": "Event Position",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "java.util.Map<java.lang.String,
com.azure.messaging.eventhubs.models.EventPosition>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the map containing
the event [...]
"prefetchCount": { "kind": "property", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the count used by
the receiver to control the number of events the Event Hub consumer w [...]
"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 [...]
@@ -42,8 +42,9 @@
"producerAsyncClient": { "kind": "property", "displayName": "Producer
Async Client", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.eventhubs.EventHubProducerAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the
EventHubProducer [...]
"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 [...]
"connectionString": { "kind": "property", "displayName": "Connection
String", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Instead of supplying
namespace, sharedAccessKey, sharedAccessName ... etc, you can just supply t
[...]
- "sharedAccessKey": { "kind": "property", "displayName": "Shared Access
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The generated value for
the SharedAccessName" },
- "sharedAccessName": { "kind": "property", "displayName": "Shared Access
Name", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The name you chose for
your EventHubs SAS keys" }
+ "sharedAccessKey": { "kind": "property", "displayName": "Shared Access
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The generated value for
the SharedAccessName." },
+ "sharedAccessName": { "kind": "property", "displayName": "Shared Access
Name", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The name you chose for
your EventHubs SAS keys." },
+ "tokenCredential": { "kind": "property", "displayName": "Token
Credential", "group": "security", "label": "security", "required": false,
"type": "object", "javaType": "com.azure.core.credential.TokenCredential",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Still another way of
authentication (beside supplying namespace, sharedAc [...]
},
"headers": {
"CamelAzureEventHubsPartitionKey": { "kind": "header", "displayName": "",
"group": "common", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "(producer) Overrides the hashing key to be provided for
the batch of events, which instructs the Event Hubs service to map this key to
a specific partition. (consumer) It sets the partition hashing key if it was
set when originally publishing t [...]
@@ -56,18 +57,18 @@
"CamelAzureEventHubsCheckpointUpdatedBy": { "kind": "header",
"displayName": "", "group": "consumer", "label": "consumer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "It sets the reason for the checkpoint
to have been updated. This is only present on a received EventData.",
"constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#CHECKPOINT_UPDATED_BY"
}
},
"properties": {
- "namespace": { "kind": "path", "displayName": "Namespace", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "EventHubs namespace
created in Azure Portal" },
- "eventHubName": { "kind": "path", "displayName": "Event Hub Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "EventHubs name under a
specific namcespace" },
+ "namespace": { "kind": "path", "displayName": "Namespace", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "EventHubs namespace
created in Azure Portal." },
+ "eventHubName": { "kind": "path", "displayName": "Event Hub Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "EventHubs name under a
specific namespace." },
"amqpRetryOptions": { "kind": "parameter", "displayName": "Amqp Retry
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.AmqpRetryOptions", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the retry policy
for EventHubAsyncClient. If not specified, the default [...]
"amqpTransportType": { "kind": "parameter", "displayName": "Amqp Transport
Type", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.AmqpTransportType", "enum": [
"Amqp", "AmqpWebSockets" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AMQP", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the tra [...]
- "blobAccessKey": { "kind": "parameter", "displayName": "Blob Access Key",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets access key for the associated azure acc
[...]
+ "blobAccessKey": { "kind": "parameter", "displayName": "Blob Access Key",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets access key for the associated azure acc
[...]
"blobAccountName": { "kind": "parameter", "displayName": "Blob Account
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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets Azure account name to be used for [...]
- "blobContainerName": { "kind": "parameter", "displayName": "Blob Container
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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets the blob container that shall [...]
- "blobStorageSharedKeyCredential": { "kind": "parameter", "displayName":
"Blob Storage Shared Key Credential", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.storage.common.StorageSharedKeyCredential", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default [...]
- "checkpointBatchSize": { "kind": "parameter", "displayName": "Checkpoint
Batch Size", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch size
between each checkpoint updates. Works jointly with checkp [...]
- "checkpointBatchTimeout": { "kind": "parameter", "displayName":
"Checkpoint Batch Timeout", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 5000,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch timeout
between each checkpoint updates. Works jointly w [...]
- "checkpointStore": { "kind": "parameter", "displayName": "Checkpoint
Store", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.eventhubs.CheckpointStore",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"BlobCheckpointStore", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the CheckpointStore
the [...]
- "consumerGroupName": { "kind": "parameter", "displayName": "Consumer Group
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "$Default", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
consumer group this consumer is associated [...]
+ "blobContainerName": { "kind": "parameter", "displayName": "Blob Container
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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets the blob container that shall [...]
+ "blobStorageSharedKeyCredential": { "kind": "parameter", "displayName":
"Blob Storage Shared Key Credential", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.storage.common.StorageSharedKeyCredential", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default [...]
+ "checkpointBatchSize": { "kind": "parameter", "displayName": "Checkpoint
Batch Size", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch size
between each checkpoint updates. Works jointly with checkp [...]
+ "checkpointBatchTimeout": { "kind": "parameter", "displayName":
"Checkpoint Batch Timeout", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 5000,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch timeout
between each checkpoint updates. Works jointly w [...]
+ "checkpointStore": { "kind": "parameter", "displayName": "Checkpoint
Store", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.eventhubs.CheckpointStore",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"BlobCheckpointStore", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the CheckpointStore
the [...]
+ "consumerGroupName": { "kind": "parameter", "displayName": "Consumer Group
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "$Default", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
consumer group this consumer is associated [...]
"eventPosition": { "kind": "parameter", "displayName": "Event Position",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "java.util.Map<java.lang.String,
com.azure.messaging.eventhubs.models.EventPosition>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the map containing
the event [...]
"prefetchCount": { "kind": "parameter", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the count used by
the receiver to control the number of events the Event Hub consumer [...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"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 [...]
@@ -78,7 +79,8 @@
"producerAsyncClient": { "kind": "parameter", "displayName": "Producer
Async Client", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.eventhubs.EventHubProducerAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the EventHubProduce
[...]
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer (advanced)", "label": "producer,advanced",
"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 other [...]
"connectionString": { "kind": "parameter", "displayName": "Connection
String", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Instead of supplying
namespace, sharedAccessKey, sharedAccessName ... etc, you can just supply [...]
- "sharedAccessKey": { "kind": "parameter", "displayName": "Shared Access
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The generated value for
the SharedAccessName" },
- "sharedAccessName": { "kind": "parameter", "displayName": "Shared Access
Name", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The name you chose for
your EventHubs SAS keys" }
+ "sharedAccessKey": { "kind": "parameter", "displayName": "Shared Access
Key", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The generated value for
the SharedAccessName." },
+ "sharedAccessName": { "kind": "parameter", "displayName": "Shared Access
Name", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "The name you chose for
your EventHubs SAS keys." },
+ "tokenCredential": { "kind": "parameter", "displayName": "Token
Credential", "group": "security", "label": "security", "required": false,
"type": "object", "javaType": "com.azure.core.credential.TokenCredential",
"deprecated": false, "autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Still another way of
authentication (beside supplying namespace, sharedA [...]
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
index 3186c470270..bfc71295220 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/netty-http.json
@@ -143,7 +143,9 @@
"httpMethodRestrict": { "kind": "parameter", "displayName": "Http Method
Restrict", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description": "To
disable HTTP methods on the Netty HTTP consumer. You can specify multiple
separated by comma." },
"logWarnOnBadRequest": { "kind": "parameter", "displayName": "Log Warn On
Bad Request", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "Whether Netty HTTP
server should log a WARN if decoding [...]
"mapHeaders": { "kind": "parameter", "displayName": "Map Headers",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "If this option is
enabled, then during binding from Netty to Camel Message th [...]
+ "maxChunkSize": { "kind": "parameter", "displayName": "Max Chunk Size",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "The maximum length of
the content or each chunk. If the content length (or t [...]
"maxHeaderSize": { "kind": "parameter", "displayName": "Max Header Size",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "The maximum length of
all headers. If the sum of the length of each header [...]
+ "maxInitialLineLength": { "kind": "parameter", "displayName": "Max Initial
Line Length", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 4096,
"configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "The maximum length of
the initial line (e.g. {code GET \/ H [...]
"nettyServerBootstrapFactory": { "kind": "parameter", "displayName":
"Netty Server Bootstrap Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.netty.NettyServerBootstrapFactory", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuration", "description": "To use a cu [...]
"nettySharedHttpServer": { "kind": "parameter", "displayName": "Netty
Shared Http Server", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.netty.http.NettySharedHttpServer", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a shared
Netty HTTP server. See Netty HTTP Server Example for more details." },
"noReplyLogLevel": { "kind": "parameter", "displayName": "No Reply Log
Level", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "WARN", "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
"configurationField": "configuratio [...]
diff --git
a/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
b/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
index 3b6059d6fe0..66b7588abb4 100644
---
a/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
+++
b/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
@@ -35,7 +35,7 @@
{
"name": "camel.component.azure-eventhubs.blob-access-key",
"type": "java.lang.String",
- "description": "In case you chose the default BlobCheckpointStore, this
sets access key for the associated azure account name to be used for
authentication with azure blob services",
+ "description": "In case you chose the default BlobCheckpointStore, this
sets access key for the associated azure account name to be used for
authentication with azure blob services.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration"
},
{
@@ -47,7 +47,7 @@
{
"name": "camel.component.azure-eventhubs.blob-container-name",
"type": "java.lang.String",
- "description": "In case you chose the default BlobCheckpointStore, this
sets the blob container that shall be used by the BlobCheckpointStore to store
the checkpoint offsets",
+ "description": "In case you chose the default BlobCheckpointStore, this
sets the blob container that shall be used by the BlobCheckpointStore to store
the checkpoint offsets.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration"
},
{
@@ -66,14 +66,14 @@
{
"name": "camel.component.azure-eventhubs.checkpoint-batch-size",
"type": "java.lang.Integer",
- "description": "Sets the batch size between each checkpoint updates.
Works jointly with checkpointBatchTimeout",
+ "description": "Sets the batch size between each checkpoint updates.
Works jointly with checkpointBatchTimeout.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration",
"defaultValue": 500
},
{
"name": "camel.component.azure-eventhubs.checkpoint-batch-timeout",
"type": "java.lang.Integer",
- "description": "Sets the batch timeout between each checkpoint updates.
Works jointly with checkpointBatchSize",
+ "description": "Sets the batch timeout between each checkpoint updates.
Works jointly with checkpointBatchSize.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration",
"defaultValue": 5000
},
@@ -98,7 +98,7 @@
{
"name": "camel.component.azure-eventhubs.consumer-group-name",
"type": "java.lang.String",
- "description": "Sets the name of the consumer group this consumer is
associated with. Events are read in the context of this group. The name of the
consumer group that is created by default is {link #DEFAULT_CONSUMER_GROUP_NAME
$Default}.",
+ "description": "Sets the name of the consumer group this consumer is
associated with. Events are read in the context of this group. The name of the
consumer group that is created by default is {code $Default}.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration",
"defaultValue": "$Default"
},
@@ -154,13 +154,19 @@
{
"name": "camel.component.azure-eventhubs.shared-access-key",
"type": "java.lang.String",
- "description": "The generated value for the SharedAccessName",
+ "description": "The generated value for the SharedAccessName.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration"
},
{
"name": "camel.component.azure-eventhubs.shared-access-name",
"type": "java.lang.String",
- "description": "The name you chose for your EventHubs SAS keys",
+ "description": "The name you chose for your EventHubs SAS keys.",
+ "sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration"
+ },
+ {
+ "name": "camel.component.azure-eventhubs.token-credential",
+ "type": "com.azure.core.credential.TokenCredential",
+ "description": "Still another way of authentication (beside supplying
namespace, sharedAccessKey, sharedAccessName or connection string) is through
Azure-AD authentication using an implementation instance of TokenCredential.
The option is a com.azure.core.credential.TokenCredential type.",
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration"
}
],
diff --git
a/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
b/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
index f18492d8056..cf6ed9c91b5 100644
---
a/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
+++
b/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
@@ -20,6 +20,7 @@ import java.util.Map;
import javax.annotation.Generated;
import com.azure.core.amqp.AmqpRetryOptions;
import com.azure.core.amqp.AmqpTransportType;
+import com.azure.core.credential.TokenCredential;
import com.azure.messaging.eventhubs.CheckpointStore;
import com.azure.messaging.eventhubs.EventHubProducerAsyncClient;
import com.azure.messaging.eventhubs.models.EventPosition;
@@ -64,7 +65,7 @@ public class EventHubsComponentConfiguration
/**
* In case you chose the default BlobCheckpointStore, this sets access key
* for the associated azure account name to be used for authentication with
- * azure blob services
+ * azure blob services.
*/
private String blobAccessKey;
/**
@@ -75,7 +76,7 @@ public class EventHubsComponentConfiguration
/**
* In case you chose the default BlobCheckpointStore, this sets the blob
* container that shall be used by the BlobCheckpointStore to store the
- * checkpoint offsets
+ * checkpoint offsets.
*/
private String blobContainerName;
/**
@@ -96,12 +97,12 @@ public class EventHubsComponentConfiguration
private Boolean bridgeErrorHandler = false;
/**
* Sets the batch size between each checkpoint updates. Works jointly with
- * checkpointBatchTimeout
+ * checkpointBatchTimeout.
*/
private Integer checkpointBatchSize = 500;
/**
* Sets the batch timeout between each checkpoint updates. Works jointly
- * with checkpointBatchSize
+ * with checkpointBatchSize.
*/
private Integer checkpointBatchTimeout = 5000;
/**
@@ -117,8 +118,7 @@ public class EventHubsComponentConfiguration
/**
* Sets the name of the consumer group this consumer is associated with.
* Events are read in the context of this group. The name of the consumer
- * group that is created by default is {link #DEFAULT_CONSUMER_GROUP_NAME
- * $Default}.
+ * group that is created by default is {code $Default}.
*/
private String consumerGroupName = "$Default";
/**
@@ -195,13 +195,21 @@ public class EventHubsComponentConfiguration
*/
private String connectionString;
/**
- * The generated value for the SharedAccessName
+ * The generated value for the SharedAccessName.
*/
private String sharedAccessKey;
/**
- * The name you chose for your EventHubs SAS keys
+ * The name you chose for your EventHubs SAS keys.
*/
private String sharedAccessName;
+ /**
+ * Still another way of authentication (beside supplying namespace,
+ * sharedAccessKey, sharedAccessName or connection string) is through
+ * Azure-AD authentication using an implementation instance of
+ * TokenCredential. The option is a
+ * com.azure.core.credential.TokenCredential type.
+ */
+ private TokenCredential tokenCredential;
public AmqpRetryOptions getAmqpRetryOptions() {
return amqpRetryOptions;
@@ -380,4 +388,12 @@ public class EventHubsComponentConfiguration
public void setSharedAccessName(String sharedAccessName) {
this.sharedAccessName = sharedAccessName;
}
+
+ public TokenCredential getTokenCredential() {
+ return tokenCredential;
+ }
+
+ public void setTokenCredential(TokenCredential tokenCredential) {
+ this.tokenCredential = tokenCredential;
+ }
}
\ No newline at end of file
diff --git
a/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConverter.java
b/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConverter.java
index f4e0557945d..f41c28d7bb6 100644
---
a/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConverter.java
+++
b/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConverter.java
@@ -46,6 +46,7 @@ public class EventHubsComponentConverter implements
GenericConverter {
answer.add(new ConvertiblePair(String.class,
com.azure.storage.common.StorageSharedKeyCredential.class));
answer.add(new ConvertiblePair(String.class,
com.azure.messaging.eventhubs.CheckpointStore.class));
answer.add(new ConvertiblePair(String.class,
com.azure.messaging.eventhubs.EventHubProducerAsyncClient.class));
+ answer.add(new ConvertiblePair(String.class,
com.azure.core.credential.TokenCredential.class));
return answer;
}
@@ -67,6 +68,7 @@ public class EventHubsComponentConverter implements
GenericConverter {
case "com.azure.storage.common.StorageSharedKeyCredential": return
applicationContext.getBean(ref,
com.azure.storage.common.StorageSharedKeyCredential.class);
case "com.azure.messaging.eventhubs.CheckpointStore": return
applicationContext.getBean(ref,
com.azure.messaging.eventhubs.CheckpointStore.class);
case "com.azure.messaging.eventhubs.EventHubProducerAsyncClient":
return applicationContext.getBean(ref,
com.azure.messaging.eventhubs.EventHubProducerAsyncClient.class);
+ case "com.azure.core.credential.TokenCredential": return
applicationContext.getBean(ref,
com.azure.core.credential.TokenCredential.class);
}
return null;
}
