This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6dd35bcb4e1783fd5f1fb6c34aeab7360156a0b3
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jul 22 15:13:54 2022 +0200
Regen
---
.../camel/catalog/components/azure-eventhubs.json | 7 +-
.../dsl/AzureEventhubsComponentBuilderFactory.java | 36 ++++++++++
.../dsl/EventHubsEndpointBuilderFactory.java | 83 ++++++++++++++++++++++
3 files changed, 125 insertions(+), 1 deletion(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-eventhubs.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-eventhubs.json
index 3a672a2648a..00828d6c79e 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-eventhubs.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-eventhubs.json
@@ -30,6 +30,8 @@
"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 [...]
"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 [...]
@@ -50,7 +52,8 @@
"CamelAzureEventHubsEnqueuedTime": { "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"Instant", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "It sets the instant, in UTC, of when the event
was enqueued in the Event Hub partition. This is only present on a received
EventData.", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#ENQUEUED_TIME" },
"CamelAzureEventHubsSequenceNumber": { "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"Long", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "It sets the sequence number assigned to the
event when it was enqueued in the associated Event Hub partition. This is
unique for every message received in the Event Hub partition. This is only
present on a received EventData.", "const [...]
"CamelAzureEventHubsMetadata": { "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"Map<String, Object>", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The set of free-form event properties
which may be used for passing metadata associated with the event with the event
body during Event Hubs operations.", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsC [...]
- "CamelMessageTimestamp": { "kind": "header", "displayName": "", "group":
"consumer", "label": "consumer", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The timestamp of the message", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#MESSAGE_TIMESTAMP"
}
+ "CamelMessageTimestamp": { "kind": "header", "displayName": "", "group":
"consumer", "label": "consumer", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The timestamp of the message", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#MESSAGE_TIMESTAMP"
},
+ "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" },
@@ -61,6 +64,8 @@
"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 [...]
"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 [...]
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
index 9f0e9d142df..ffc3e47dc81 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
@@ -191,6 +191,40 @@ public interface AzureEventhubsComponentBuilderFactory {
doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
+ /**
+ * Sets the batch size between each checkpoint updates. Works jointly
+ * with checkpointBatchTimeout.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 500
+ * Group: consumer
+ *
+ * @param checkpointBatchSize the value to set
+ * @return the dsl builder
+ */
+ default AzureEventhubsComponentBuilder checkpointBatchSize(
+ int checkpointBatchSize) {
+ doSetProperty("checkpointBatchSize", checkpointBatchSize);
+ return this;
+ }
+ /**
+ * Sets the batch timeout between each checkpoint updates. Works
jointly
+ * with checkpointBatchSize.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 5000
+ * Group: consumer
+ *
+ * @param checkpointBatchTimeout the value to set
+ * @return the dsl builder
+ */
+ default AzureEventhubsComponentBuilder checkpointBatchTimeout(
+ int checkpointBatchTimeout) {
+ doSetProperty("checkpointBatchTimeout", checkpointBatchTimeout);
+ return this;
+ }
/**
* Sets the CheckpointStore the EventProcessorClient will use for
* storing partition ownership and checkpoint information. Users can,
@@ -461,6 +495,8 @@ public interface AzureEventhubsComponentBuilderFactory {
case "blobContainerName":
getOrCreateConfiguration((EventHubsComponent)
component).setBlobContainerName((java.lang.String) value); return true;
case "blobStorageSharedKeyCredential":
getOrCreateConfiguration((EventHubsComponent)
component).setBlobStorageSharedKeyCredential((com.azure.storage.common.StorageSharedKeyCredential)
value); return true;
case "bridgeErrorHandler": ((EventHubsComponent)
component).setBridgeErrorHandler((boolean) value); return true;
+ case "checkpointBatchSize":
getOrCreateConfiguration((EventHubsComponent)
component).setCheckpointBatchSize((int) value); return true;
+ case "checkpointBatchTimeout":
getOrCreateConfiguration((EventHubsComponent)
component).setCheckpointBatchTimeout((int) value); return true;
case "checkpointStore":
getOrCreateConfiguration((EventHubsComponent)
component).setCheckpointStore((com.azure.messaging.eventhubs.CheckpointStore)
value); return true;
case "consumerGroupName":
getOrCreateConfiguration((EventHubsComponent)
component).setConsumerGroupName((java.lang.String) value); return true;
case "eventPosition":
getOrCreateConfiguration((EventHubsComponent)
component).setEventPosition((java.util.Map) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
index a291e45b284..4d718adff50 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
@@ -199,6 +199,74 @@ public interface EventHubsEndpointBuilderFactory {
doSetProperty("blobStorageSharedKeyCredential",
blobStorageSharedKeyCredential);
return this;
}
+ /**
+ * Sets the batch size between each checkpoint updates. Works jointly
+ * with checkpointBatchTimeout.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 500
+ * Group: consumer
+ *
+ * @param checkpointBatchSize the value to set
+ * @return the dsl builder
+ */
+ default EventHubsEndpointConsumerBuilder checkpointBatchSize(
+ int checkpointBatchSize) {
+ doSetProperty("checkpointBatchSize", checkpointBatchSize);
+ return this;
+ }
+ /**
+ * Sets the batch size between each checkpoint updates. Works jointly
+ * with checkpointBatchTimeout.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 500
+ * Group: consumer
+ *
+ * @param checkpointBatchSize the value to set
+ * @return the dsl builder
+ */
+ default EventHubsEndpointConsumerBuilder checkpointBatchSize(
+ String checkpointBatchSize) {
+ doSetProperty("checkpointBatchSize", checkpointBatchSize);
+ return this;
+ }
+ /**
+ * Sets the batch timeout between each checkpoint updates. Works
jointly
+ * with checkpointBatchSize.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 5000
+ * Group: consumer
+ *
+ * @param checkpointBatchTimeout the value to set
+ * @return the dsl builder
+ */
+ default EventHubsEndpointConsumerBuilder checkpointBatchTimeout(
+ int checkpointBatchTimeout) {
+ doSetProperty("checkpointBatchTimeout", checkpointBatchTimeout);
+ return this;
+ }
+ /**
+ * Sets the batch timeout between each checkpoint updates. Works
jointly
+ * with checkpointBatchSize.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 5000
+ * Group: consumer
+ *
+ * @param checkpointBatchTimeout the value to set
+ * @return the dsl builder
+ */
+ default EventHubsEndpointConsumerBuilder checkpointBatchTimeout(
+ String checkpointBatchTimeout) {
+ doSetProperty("checkpointBatchTimeout", checkpointBatchTimeout);
+ return this;
+ }
/**
* Sets the CheckpointStore the EventProcessorClient will use for
* storing partition ownership and checkpoint information. Users can,
@@ -1117,6 +1185,21 @@ public interface EventHubsEndpointBuilderFactory {
public String messageTimestamp() {
return "MessageTimestamp";
}
+
+ /**
+ * It sets the reason for the checkpoint to have been updated. This is
+ * only present on a received EventData.
+ *
+ * The option is a: {@code String} type.
+ *
+ * Group: consumer
+ *
+ * @return the name of the header {@code
+ * AzureEventHubsCheckpointUpdatedBy}.
+ */
+ public String azureEventHubsCheckpointUpdatedBy() {
+ return "AzureEventHubsCheckpointUpdatedBy";
+ }
}
static EventHubsEndpointBuilder endpointBuilder(
String componentName,
