This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4c9503aa5dc2bd11ade933dce54ae1d053ed4f21
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Apr 16 15:11:08 2021 +0200
CAMEL-16512 - Camel-Azure components: mark the clients as autowired
---
.../catalog/docs/azure-eventhubs-component.adoc | 10 +-
.../eventhubs/EventHubsComponentConfigurer.java | 11 +-
.../eventhubs/EventHubsEndpointConfigurer.java | 11 +-
.../eventhubs/EventHubsEndpointUriFactory.java | 3 +-
.../component/azure/eventhubs/azure-eventhubs.json | 6 +-
.../src/main/docs/azure-eventhubs-component.adoc | 10 +-
.../azure/eventhubs/EventHubsComponent.java | 4 -
.../azure/eventhubs/EventHubsComponentTest.java | 1 -
.../dsl/AzureEventhubsComponentBuilderFactory.java | 19 ----
.../dsl/EventHubsEndpointBuilderFactory.java | 111 ---------------------
.../ROOT/pages/azure-eventhubs-component.adoc | 10 +-
11 files changed, 25 insertions(+), 171 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-eventhubs-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-eventhubs-component.adoc
index 2cd40c3..d1df248 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-eventhubs-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-eventhubs-component.adoc
@@ -77,7 +77,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (21 parameters):
+=== Query Parameters (20 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -85,7 +85,6 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amqpRetryOptions* (common) | Sets the retry policy for EventHubAsyncClient.
If not specified, the default retry options are used. | | AmqpRetryOptions
| *amqpTransportType* (common) | Sets the transport type by which all the
communication with Azure Event Hubs occurs. Default value is
AmqpTransportType#AMQP. There are 2 enums and the value can be one of: Amqp,
AmqpWebSockets | AMQP | AmqpTransportType
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *blobAccessKey* (consumer) | 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 | | String
| *blobAccountName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets Azure account name to be used for authentication
with azure blob services. | | String
| *blobContainerName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets the blob container that shall be used by the
BlobCheckpointStore to store the checkpoint offsets | | String
@@ -100,7 +99,7 @@ with the following path and query parameters:
| *lazyStartProducer* (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 processed
then creating and [...]
| *partitionId* (producer) | Sets the identifier of the Event Hub partition
that the events will be sent to. If the identifier is not specified, the Event
Hubs service will be responsible for routing events that are sent to an
available partition. | | String
| *partitionKey* (producer) | Sets a hashing key to be provided for the batch
of events, which instructs the Event Hubs service to map this key to a specific
partition. The selection of a partition is stable for a given partition hashing
key. Should any other batches of events be sent using the same exact partition
hashing key, the Event Hubs service will route them all to the same partition.
This should be specified only when there is a need to group events by
partition, but there is fl [...]
-| *producerAsyncClient* (producer) | Sets the EventHubProducerAsyncClient.An
asynchronous producer responsible for transmitting EventData to a specific
Event Hub, grouped together in batches. Depending on the options specified when
creating an \{linkEventDataBatch}, the events may be automatically routed to an
available partition or specific to a partition. Use by this component to
produce the data in camel producer. | | EventHubProducerAsyncClient
+| *producerAsyncClient* (producer) | *Autowired* Sets the
EventHubProducerAsyncClient.An asynchronous producer responsible for
transmitting EventData to a specific Event Hub, grouped together in batches.
Depending on the options specified when creating an \{linkEventDataBatch}, the
events may be automatically routed to an available partition or specific to a
partition. Use by this component to produce the data in camel producer. | |
EventHubProducerAsyncClient
| *connectionString* (security) | Instead of supplying namespace,
sharedAccessKey, sharedAccessName ... etc, you can just supply the connection
string for your eventHub. The connection string for EventHubs already include
all the necessary information to connection to your EventHub. To learn on how
to generate the connection string, take a look at this documentation:
\https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string
| | String
| *sharedAccessKey* (security) | The generated value for the SharedAccessName
| | String
| *sharedAccessName* (security) | The name you chose for your EventHubs SAS
keys | | String
@@ -108,7 +107,7 @@ with the following path and query parameters:
// endpoint options: END
// component options: START
-The Azure Event Hubs component supports 21 options, which are listed below.
+The Azure Event Hubs component supports 20 options, which are listed below.
@@ -117,7 +116,6 @@ The Azure Event Hubs component supports 21 options, which
are listed below.
| Name | Description | Default | Type
| *amqpRetryOptions* (common) | Sets the retry policy for EventHubAsyncClient.
If not specified, the default retry options are used. | | AmqpRetryOptions
| *amqpTransportType* (common) | Sets the transport type by which all the
communication with Azure Event Hubs occurs. Default value is
AmqpTransportType#AMQP. There are 2 enums and the value can be one of: Amqp,
AmqpWebSockets | AMQP | AmqpTransportType
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configurations | |
EventHubsConfiguration
| *blobAccessKey* (consumer) | 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 | | String
| *blobAccountName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets Azure account name to be used for authentication
with azure blob services. | | String
@@ -131,7 +129,7 @@ The Azure Event Hubs component supports 21 options, which
are listed below.
| *lazyStartProducer* (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 processed
then creating and [...]
| *partitionId* (producer) | Sets the identifier of the Event Hub partition
that the events will be sent to. If the identifier is not specified, the Event
Hubs service will be responsible for routing events that are sent to an
available partition. | | String
| *partitionKey* (producer) | Sets a hashing key to be provided for the batch
of events, which instructs the Event Hubs service to map this key to a specific
partition. The selection of a partition is stable for a given partition hashing
key. Should any other batches of events be sent using the same exact partition
hashing key, the Event Hubs service will route them all to the same partition.
This should be specified only when there is a need to group events by
partition, but there is fl [...]
-| *producerAsyncClient* (producer) | Sets the EventHubProducerAsyncClient.An
asynchronous producer responsible for transmitting EventData to a specific
Event Hub, grouped together in batches. Depending on the options specified when
creating an \{linkEventDataBatch}, the events may be automatically routed to an
available partition or specific to a partition. Use by this component to
produce the data in camel producer. | | EventHubProducerAsyncClient
+| *producerAsyncClient* (producer) | *Autowired* Sets the
EventHubProducerAsyncClient.An asynchronous producer responsible for
transmitting EventData to a specific Event Hub, grouped together in batches.
Depending on the options specified when creating an \{linkEventDataBatch}, the
events may be automatically routed to an available partition or specific to a
partition. Use by this component to produce the data in camel producer. | |
EventHubProducerAsyncClient
| *autowiredEnabled* (advanced) | 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
| *connectionString* (security) | Instead of supplying namespace,
sharedAccessKey, sharedAccessName ... etc, you can just supply the connection
string for your eventHub. The connection string for EventHubs already include
all the necessary information to connection to your EventHub. To learn on how
to generate the connection string, take a look at this documentation:
\https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string
| | String
| *sharedAccessKey* (security) | The generated value for the SharedAccessName
| | String
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentConfigurer.java
b/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentConfigurer.java
index 47175fc..43e0a8e 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentConfigurer.java
+++
b/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentConfigurer.java
@@ -32,8 +32,6 @@ public class EventHubsComponentConfigurer extends
PropertyConfigurerSupport impl
case "amqpRetryOptions":
getOrCreateConfiguration(target).setAmqpRetryOptions(property(camelContext,
com.azure.core.amqp.AmqpRetryOptions.class, value)); return true;
case "amqptransporttype":
case "amqpTransportType":
getOrCreateConfiguration(target).setAmqpTransportType(property(camelContext,
com.azure.core.amqp.AmqpTransportType.class, value)); return true;
- case "autodiscoverclient":
- case "autoDiscoverClient":
getOrCreateConfiguration(target).setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "autowiredenabled":
case "autowiredEnabled":
target.setAutowiredEnabled(property(camelContext, boolean.class, value));
return true;
case "blobaccesskey":
@@ -74,14 +72,17 @@ public class EventHubsComponentConfigurer extends
PropertyConfigurerSupport impl
}
@Override
+ public String[] getAutowiredNames() {
+ return new String[]{"producerAsyncClient"};
+ }
+
+ @Override
public Class<?> getOptionType(String name, boolean ignoreCase) {
switch (ignoreCase ? name.toLowerCase() : name) {
case "amqpretryoptions":
case "amqpRetryOptions": return
com.azure.core.amqp.AmqpRetryOptions.class;
case "amqptransporttype":
case "amqpTransportType": return
com.azure.core.amqp.AmqpTransportType.class;
- case "autodiscoverclient":
- case "autoDiscoverClient": return boolean.class;
case "autowiredenabled":
case "autowiredEnabled": return boolean.class;
case "blobaccesskey":
@@ -129,8 +130,6 @@ public class EventHubsComponentConfigurer extends
PropertyConfigurerSupport impl
case "amqpRetryOptions": return
getOrCreateConfiguration(target).getAmqpRetryOptions();
case "amqptransporttype":
case "amqpTransportType": return
getOrCreateConfiguration(target).getAmqpTransportType();
- case "autodiscoverclient":
- case "autoDiscoverClient": return
getOrCreateConfiguration(target).isAutoDiscoverClient();
case "autowiredenabled":
case "autowiredEnabled": return target.isAutowiredEnabled();
case "blobaccesskey":
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointConfigurer.java
b/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointConfigurer.java
index b57289f..256cd00 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointConfigurer.java
+++
b/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointConfigurer.java
@@ -25,8 +25,6 @@ public class EventHubsEndpointConfigurer extends
PropertyConfigurerSupport imple
case "amqpRetryOptions":
target.getConfiguration().setAmqpRetryOptions(property(camelContext,
com.azure.core.amqp.AmqpRetryOptions.class, value)); return true;
case "amqptransporttype":
case "amqpTransportType":
target.getConfiguration().setAmqpTransportType(property(camelContext,
com.azure.core.amqp.AmqpTransportType.class, value)); return true;
- case "autodiscoverclient":
- case "autoDiscoverClient":
target.getConfiguration().setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "blobaccesskey":
case "blobAccessKey":
target.getConfiguration().setBlobAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "blobaccountname":
@@ -68,14 +66,17 @@ public class EventHubsEndpointConfigurer extends
PropertyConfigurerSupport imple
}
@Override
+ public String[] getAutowiredNames() {
+ return new String[]{"producerAsyncClient"};
+ }
+
+ @Override
public Class<?> getOptionType(String name, boolean ignoreCase) {
switch (ignoreCase ? name.toLowerCase() : name) {
case "amqpretryoptions":
case "amqpRetryOptions": return
com.azure.core.amqp.AmqpRetryOptions.class;
case "amqptransporttype":
case "amqpTransportType": return
com.azure.core.amqp.AmqpTransportType.class;
- case "autodiscoverclient":
- case "autoDiscoverClient": return boolean.class;
case "blobaccesskey":
case "blobAccessKey": return java.lang.String.class;
case "blobaccountname":
@@ -124,8 +125,6 @@ public class EventHubsEndpointConfigurer extends
PropertyConfigurerSupport imple
case "amqpRetryOptions": return
target.getConfiguration().getAmqpRetryOptions();
case "amqptransporttype":
case "amqpTransportType": return
target.getConfiguration().getAmqpTransportType();
- case "autodiscoverclient":
- case "autoDiscoverClient": return
target.getConfiguration().isAutoDiscoverClient();
case "blobaccesskey":
case "blobAccessKey": return
target.getConfiguration().getBlobAccessKey();
case "blobaccountname":
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointUriFactory.java
b/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointUriFactory.java
index 272f4ab..7108aae 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointUriFactory.java
+++
b/components/camel-azure/camel-azure-eventhubs/src/generated/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpointUriFactory.java
@@ -20,10 +20,9 @@ public class EventHubsEndpointUriFactory extends
org.apache.camel.support.compon
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(23);
+ Set<String> props = new HashSet<>(22);
props.add("blobStorageSharedKeyCredential");
props.add("connectionString");
- props.add("autoDiscoverClient");
props.add("prefetchCount");
props.add("sharedAccessKey");
props.add("sharedAccessName");
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/generated/resources/org/apache/camel/component/azure/eventhubs/azure-eventhubs.json
b/components/camel-azure/camel-azure-eventhubs/src/generated/resources/org/apache/camel/component/azure/eventhubs/azure-eventhubs.json
index 0c9b04c..d47ea82 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/generated/resources/org/apache/camel/component/azure/eventhubs/azure-eventhubs.json
+++
b/components/camel-azure/camel-azure-eventhubs/src/generated/resources/org/apache/camel/component/azure/eventhubs/azure-eventhubs.json
@@ -24,7 +24,6 @@
"componentProperties": {
"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 [...]
- "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a [...]
"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
[...]
"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 [...]
@@ -38,7 +37,7 @@
"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 [...]
"partitionId": { "kind": "property", "displayName": "Partition 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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the identifier of
the Event Hub partition that the events will be sent to. If the identifier is
not [...]
"partitionKey": { "kind": "property", "displayName": "Partition Key",
"group": "producer", "label": "producer", "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": "Sets a hashing key to be
provided for the batch of events, which instructs the Event Hubs service to ma
[...]
- "producerAsyncClient": { "kind": "property", "displayName": "Producer
Async Client", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.eventhubs.EventHubProducerAsyncClient", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the
EventHubProducerAsyncClient.An asynchr [...]
+ "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" },
@@ -49,7 +48,6 @@
"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" },
"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 [...]
- "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for [...]
"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 [...]
@@ -64,7 +62,7 @@
"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 [...]
"partitionId": { "kind": "parameter", "displayName": "Partition 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.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the identifier of
the Event Hub partition that the events will be sent to. If the identifier is
not [...]
"partitionKey": { "kind": "parameter", "displayName": "Partition Key",
"group": "producer", "label": "producer", "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": "Sets a hashing key to be
provided for the batch of events, which instructs the Event Hubs service to m
[...]
- "producerAsyncClient": { "kind": "parameter", "displayName": "Producer
Async Client", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.eventhubs.EventHubProducerAsyncClient", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the
EventHubProducerAsyncClient.An asynch [...]
+ "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
[...]
"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" }
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/main/docs/azure-eventhubs-component.adoc
b/components/camel-azure/camel-azure-eventhubs/src/main/docs/azure-eventhubs-component.adoc
index 2cd40c3..d1df248 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/main/docs/azure-eventhubs-component.adoc
+++
b/components/camel-azure/camel-azure-eventhubs/src/main/docs/azure-eventhubs-component.adoc
@@ -77,7 +77,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (21 parameters):
+=== Query Parameters (20 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -85,7 +85,6 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amqpRetryOptions* (common) | Sets the retry policy for EventHubAsyncClient.
If not specified, the default retry options are used. | | AmqpRetryOptions
| *amqpTransportType* (common) | Sets the transport type by which all the
communication with Azure Event Hubs occurs. Default value is
AmqpTransportType#AMQP. There are 2 enums and the value can be one of: Amqp,
AmqpWebSockets | AMQP | AmqpTransportType
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *blobAccessKey* (consumer) | 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 | | String
| *blobAccountName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets Azure account name to be used for authentication
with azure blob services. | | String
| *blobContainerName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets the blob container that shall be used by the
BlobCheckpointStore to store the checkpoint offsets | | String
@@ -100,7 +99,7 @@ with the following path and query parameters:
| *lazyStartProducer* (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 processed
then creating and [...]
| *partitionId* (producer) | Sets the identifier of the Event Hub partition
that the events will be sent to. If the identifier is not specified, the Event
Hubs service will be responsible for routing events that are sent to an
available partition. | | String
| *partitionKey* (producer) | Sets a hashing key to be provided for the batch
of events, which instructs the Event Hubs service to map this key to a specific
partition. The selection of a partition is stable for a given partition hashing
key. Should any other batches of events be sent using the same exact partition
hashing key, the Event Hubs service will route them all to the same partition.
This should be specified only when there is a need to group events by
partition, but there is fl [...]
-| *producerAsyncClient* (producer) | Sets the EventHubProducerAsyncClient.An
asynchronous producer responsible for transmitting EventData to a specific
Event Hub, grouped together in batches. Depending on the options specified when
creating an \{linkEventDataBatch}, the events may be automatically routed to an
available partition or specific to a partition. Use by this component to
produce the data in camel producer. | | EventHubProducerAsyncClient
+| *producerAsyncClient* (producer) | *Autowired* Sets the
EventHubProducerAsyncClient.An asynchronous producer responsible for
transmitting EventData to a specific Event Hub, grouped together in batches.
Depending on the options specified when creating an \{linkEventDataBatch}, the
events may be automatically routed to an available partition or specific to a
partition. Use by this component to produce the data in camel producer. | |
EventHubProducerAsyncClient
| *connectionString* (security) | Instead of supplying namespace,
sharedAccessKey, sharedAccessName ... etc, you can just supply the connection
string for your eventHub. The connection string for EventHubs already include
all the necessary information to connection to your EventHub. To learn on how
to generate the connection string, take a look at this documentation:
\https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string
| | String
| *sharedAccessKey* (security) | The generated value for the SharedAccessName
| | String
| *sharedAccessName* (security) | The name you chose for your EventHubs SAS
keys | | String
@@ -108,7 +107,7 @@ with the following path and query parameters:
// endpoint options: END
// component options: START
-The Azure Event Hubs component supports 21 options, which are listed below.
+The Azure Event Hubs component supports 20 options, which are listed below.
@@ -117,7 +116,6 @@ The Azure Event Hubs component supports 21 options, which
are listed below.
| Name | Description | Default | Type
| *amqpRetryOptions* (common) | Sets the retry policy for EventHubAsyncClient.
If not specified, the default retry options are used. | | AmqpRetryOptions
| *amqpTransportType* (common) | Sets the transport type by which all the
communication with Azure Event Hubs occurs. Default value is
AmqpTransportType#AMQP. There are 2 enums and the value can be one of: Amqp,
AmqpWebSockets | AMQP | AmqpTransportType
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configurations | |
EventHubsConfiguration
| *blobAccessKey* (consumer) | 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 | | String
| *blobAccountName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets Azure account name to be used for authentication
with azure blob services. | | String
@@ -131,7 +129,7 @@ The Azure Event Hubs component supports 21 options, which
are listed below.
| *lazyStartProducer* (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 processed
then creating and [...]
| *partitionId* (producer) | Sets the identifier of the Event Hub partition
that the events will be sent to. If the identifier is not specified, the Event
Hubs service will be responsible for routing events that are sent to an
available partition. | | String
| *partitionKey* (producer) | Sets a hashing key to be provided for the batch
of events, which instructs the Event Hubs service to map this key to a specific
partition. The selection of a partition is stable for a given partition hashing
key. Should any other batches of events be sent using the same exact partition
hashing key, the Event Hubs service will route them all to the same partition.
This should be specified only when there is a need to group events by
partition, but there is fl [...]
-| *producerAsyncClient* (producer) | Sets the EventHubProducerAsyncClient.An
asynchronous producer responsible for transmitting EventData to a specific
Event Hub, grouped together in batches. Depending on the options specified when
creating an \{linkEventDataBatch}, the events may be automatically routed to an
available partition or specific to a partition. Use by this component to
produce the data in camel producer. | | EventHubProducerAsyncClient
+| *producerAsyncClient* (producer) | *Autowired* Sets the
EventHubProducerAsyncClient.An asynchronous producer responsible for
transmitting EventData to a specific Event Hub, grouped together in batches.
Depending on the options specified when creating an \{linkEventDataBatch}, the
events may be automatically routed to an available partition or specific to a
partition. Use by this component to produce the data in camel producer. | |
EventHubProducerAsyncClient
| *autowiredEnabled* (advanced) | 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
| *connectionString* (security) | Instead of supplying namespace,
sharedAccessKey, sharedAccessName ... etc, you can just supply the connection
string for your eventHub. The connection string for EventHubs already include
all the necessary information to connection to your EventHub. To learn on how
to generate the connection string, take a look at this documentation:
\https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string
| | String
| *sharedAccessKey* (security) | The generated value for the SharedAccessName
| | String
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsComponent.java
b/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsComponent.java
index 01f08f2..61607de 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsComponent.java
+++
b/components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsComponent.java
@@ -17,11 +17,7 @@
package org.apache.camel.component.azure.eventhubs;
import java.util.Map;
-import java.util.Set;
-import java.util.function.Consumer;
-import java.util.function.Supplier;
-import com.azure.messaging.eventhubs.EventHubProducerAsyncClient;
import org.apache.camel.Endpoint;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.annotations.Component;
diff --git
a/components/camel-azure/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentTest.java
b/components/camel-azure/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentTest.java
index 6ffdbb0..89b7afb 100644
---
a/components/camel-azure/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentTest.java
+++
b/components/camel-azure/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsComponentTest.java
@@ -120,7 +120,6 @@ class EventHubsComponentTest extends CamelTestSupport {
assertEquals("DummyAccessKeyName",
endpoint.getConfiguration().getSharedAccessName());
assertEquals("DummyKey",
endpoint.getConfiguration().getSharedAccessKey());
assertEquals(100, endpoint.getConfiguration().getPrefetchCount());
- assertTrue(endpoint.getConfiguration().isAutoDiscoverClient());
}
private String getErrorMessage(final String uri) {
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
index 5030c3d..10fbe2b 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureEventhubsComponentBuilderFactory.java
@@ -92,24 +92,6 @@ public interface AzureEventhubsComponentBuilderFactory {
return this;
}
/**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default AzureEventhubsComponentBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
* The component configurations.
*
* The option is a:
@@ -479,7 +461,6 @@ public interface AzureEventhubsComponentBuilderFactory {
switch (name) {
case "amqpRetryOptions":
getOrCreateConfiguration((EventHubsComponent)
component).setAmqpRetryOptions((com.azure.core.amqp.AmqpRetryOptions) value);
return true;
case "amqpTransportType":
getOrCreateConfiguration((EventHubsComponent)
component).setAmqpTransportType((com.azure.core.amqp.AmqpTransportType) value);
return true;
- case "autoDiscoverClient":
getOrCreateConfiguration((EventHubsComponent)
component).setAutoDiscoverClient((boolean) value); return true;
case "configuration": ((EventHubsComponent)
component).setConfiguration((org.apache.camel.component.azure.eventhubs.EventHubsConfiguration)
value); return true;
case "blobAccessKey":
getOrCreateConfiguration((EventHubsComponent)
component).setBlobAccessKey((java.lang.String) value); return true;
case "blobAccountName":
getOrCreateConfiguration((EventHubsComponent)
component).setBlobAccountName((java.lang.String) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
index b36248a..0ee225a 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/EventHubsEndpointBuilderFactory.java
@@ -116,43 +116,6 @@ public interface EventHubsEndpointBuilderFactory {
return this;
}
/**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EventHubsEndpointConsumerBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EventHubsEndpointConsumerBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
* 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.
@@ -638,43 +601,6 @@ public interface EventHubsEndpointBuilderFactory {
return this;
}
/**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EventHubsEndpointProducerBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EventHubsEndpointProducerBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
* 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
@@ -952,43 +878,6 @@ public interface EventHubsEndpointBuilderFactory {
return this;
}
/**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EventHubsEndpointBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component
will
- * look for a client instance in the registry automatically otherwise
it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default EventHubsEndpointBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
* Instead of supplying namespace, sharedAccessKey, sharedAccessName
...
* etc, you can just supply the connection string for your eventHub.
The
* connection string for EventHubs already include all the necessary
diff --git a/docs/components/modules/ROOT/pages/azure-eventhubs-component.adoc
b/docs/components/modules/ROOT/pages/azure-eventhubs-component.adoc
index 662063d..bc05f9b 100644
--- a/docs/components/modules/ROOT/pages/azure-eventhubs-component.adoc
+++ b/docs/components/modules/ROOT/pages/azure-eventhubs-component.adoc
@@ -79,7 +79,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (21 parameters):
+=== Query Parameters (20 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -87,7 +87,6 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amqpRetryOptions* (common) | Sets the retry policy for EventHubAsyncClient.
If not specified, the default retry options are used. | | AmqpRetryOptions
| *amqpTransportType* (common) | Sets the transport type by which all the
communication with Azure Event Hubs occurs. Default value is
AmqpTransportType#AMQP. There are 2 enums and the value can be one of: Amqp,
AmqpWebSockets | AMQP | AmqpTransportType
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *blobAccessKey* (consumer) | 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 | | String
| *blobAccountName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets Azure account name to be used for authentication
with azure blob services. | | String
| *blobContainerName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets the blob container that shall be used by the
BlobCheckpointStore to store the checkpoint offsets | | String
@@ -102,7 +101,7 @@ with the following path and query parameters:
| *lazyStartProducer* (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 processed
then creating and [...]
| *partitionId* (producer) | Sets the identifier of the Event Hub partition
that the events will be sent to. If the identifier is not specified, the Event
Hubs service will be responsible for routing events that are sent to an
available partition. | | String
| *partitionKey* (producer) | Sets a hashing key to be provided for the batch
of events, which instructs the Event Hubs service to map this key to a specific
partition. The selection of a partition is stable for a given partition hashing
key. Should any other batches of events be sent using the same exact partition
hashing key, the Event Hubs service will route them all to the same partition.
This should be specified only when there is a need to group events by
partition, but there is fl [...]
-| *producerAsyncClient* (producer) | Sets the EventHubProducerAsyncClient.An
asynchronous producer responsible for transmitting EventData to a specific
Event Hub, grouped together in batches. Depending on the options specified when
creating an \{linkEventDataBatch}, the events may be automatically routed to an
available partition or specific to a partition. Use by this component to
produce the data in camel producer. | | EventHubProducerAsyncClient
+| *producerAsyncClient* (producer) | *Autowired* Sets the
EventHubProducerAsyncClient.An asynchronous producer responsible for
transmitting EventData to a specific Event Hub, grouped together in batches.
Depending on the options specified when creating an \{linkEventDataBatch}, the
events may be automatically routed to an available partition or specific to a
partition. Use by this component to produce the data in camel producer. | |
EventHubProducerAsyncClient
| *connectionString* (security) | Instead of supplying namespace,
sharedAccessKey, sharedAccessName ... etc, you can just supply the connection
string for your eventHub. The connection string for EventHubs already include
all the necessary information to connection to your EventHub. To learn on how
to generate the connection string, take a look at this documentation:
\https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string
| | String
| *sharedAccessKey* (security) | The generated value for the SharedAccessName
| | String
| *sharedAccessName* (security) | The name you chose for your EventHubs SAS
keys | | String
@@ -110,7 +109,7 @@ with the following path and query parameters:
// endpoint options: END
// component options: START
-The Azure Event Hubs component supports 21 options, which are listed below.
+The Azure Event Hubs component supports 20 options, which are listed below.
@@ -119,7 +118,6 @@ The Azure Event Hubs component supports 21 options, which
are listed below.
| Name | Description | Default | Type
| *amqpRetryOptions* (common) | Sets the retry policy for EventHubAsyncClient.
If not specified, the default retry options are used. | | AmqpRetryOptions
| *amqpTransportType* (common) | Sets the transport type by which all the
communication with Azure Event Hubs occurs. Default value is
AmqpTransportType#AMQP. There are 2 enums and the value can be one of: Amqp,
AmqpWebSockets | AMQP | AmqpTransportType
-| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configurations | |
EventHubsConfiguration
| *blobAccessKey* (consumer) | 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 | | String
| *blobAccountName* (consumer) | In case you chose the default
BlobCheckpointStore, this sets Azure account name to be used for authentication
with azure blob services. | | String
@@ -133,7 +131,7 @@ The Azure Event Hubs component supports 21 options, which
are listed below.
| *lazyStartProducer* (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 processed
then creating and [...]
| *partitionId* (producer) | Sets the identifier of the Event Hub partition
that the events will be sent to. If the identifier is not specified, the Event
Hubs service will be responsible for routing events that are sent to an
available partition. | | String
| *partitionKey* (producer) | Sets a hashing key to be provided for the batch
of events, which instructs the Event Hubs service to map this key to a specific
partition. The selection of a partition is stable for a given partition hashing
key. Should any other batches of events be sent using the same exact partition
hashing key, the Event Hubs service will route them all to the same partition.
This should be specified only when there is a need to group events by
partition, but there is fl [...]
-| *producerAsyncClient* (producer) | Sets the EventHubProducerAsyncClient.An
asynchronous producer responsible for transmitting EventData to a specific
Event Hub, grouped together in batches. Depending on the options specified when
creating an \{linkEventDataBatch}, the events may be automatically routed to an
available partition or specific to a partition. Use by this component to
produce the data in camel producer. | | EventHubProducerAsyncClient
+| *producerAsyncClient* (producer) | *Autowired* Sets the
EventHubProducerAsyncClient.An asynchronous producer responsible for
transmitting EventData to a specific Event Hub, grouped together in batches.
Depending on the options specified when creating an \{linkEventDataBatch}, the
events may be automatically routed to an available partition or specific to a
partition. Use by this component to produce the data in camel producer. | |
EventHubProducerAsyncClient
| *autowiredEnabled* (advanced) | 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
| *connectionString* (security) | Instead of supplying namespace,
sharedAccessKey, sharedAccessName ... etc, you can just supply the connection
string for your eventHub. The connection string for EventHubs already include
all the necessary information to connection to your EventHub. To learn on how
to generate the connection string, take a look at this documentation:
\https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string
| | String
| *sharedAccessKey* (security) | The generated value for the SharedAccessName
| | String
