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.git
commit f7e92a0da9c394dc248791e2c5ecfac8d97b0b15
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Feb 26 08:51:18 2022 +0100
CAMEL-17706: Polished
---
.../servicebus/ServiceBusEndpointUriFactory.java | 5 +++--
.../component/azure/servicebus/azure-servicebus.json | 20 ++++++++++----------
.../azure/servicebus/ServiceBusConfiguration.java | 18 +++++++++---------
3 files changed, 22 insertions(+), 21 deletions(-)
diff --git
a/components/camel-azure/camel-azure-servicebus/src/generated/java/org/apache/camel/component/azure/servicebus/ServiceBusEndpointUriFactory.java
b/components/camel-azure/camel-azure-servicebus/src/generated/java/org/apache/camel/component/azure/servicebus/ServiceBusEndpointUriFactory.java
index 9831db3..8f46884 100644
---
a/components/camel-azure/camel-azure-servicebus/src/generated/java/org/apache/camel/component/azure/servicebus/ServiceBusEndpointUriFactory.java
+++
b/components/camel-azure/camel-azure-servicebus/src/generated/java/org/apache/camel/component/azure/servicebus/ServiceBusEndpointUriFactory.java
@@ -34,8 +34,8 @@ public class ServiceBusEndpointUriFactory extends
org.apache.camel.support.compo
props.add("topicOrQueueName");
props.add("serviceBusType");
props.add("receiverAsyncClient");
- props.add("fullyQualifiedNamespace");
props.add("exchangePattern");
+ props.add("fullyQualifiedNamespace");
props.add("producerOperation");
props.add("amqpTransportType");
props.add("serviceBusReceiveMode");
@@ -49,8 +49,9 @@ public class ServiceBusEndpointUriFactory extends
org.apache.camel.support.compo
props.add("exceptionHandler");
props.add("maxAutoLockRenewDuration");
PROPERTY_NAMES = Collections.unmodifiableSet(props);
- Set<String> secretProps = new HashSet<>(1);
+ Set<String> secretProps = new HashSet<>(2);
secretProps.add("connectionString");
+ secretProps.add("tokenCredential");
SECRET_PROPERTY_NAMES = Collections.unmodifiableSet(secretProps);
MULTI_VALUE_PREFIXES = Collections.emptySet();
}
diff --git
a/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
b/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
index b6773a3..f36b10e 100644
---
a/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
+++
b/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
@@ -26,16 +26,14 @@
"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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the tr [...]
"clientOptions": { "kind": "property", "displayName": "Client Options",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.core.util.ClientOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the ClientOptions
to be sent from the client built from this builder, enabling cu [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
- "fullyQualifiedNamespace": { "kind": "property", "displayName": "Fully
Qualified Namespace", "group": "common", "label": "common", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Fully Qualified
Namespace of the service bus" },
"proxyOptions": { "kind": "property", "displayName": "Proxy Options",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.core.amqp.ProxyOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a proxy is conf [...]
"serviceBusType": { "kind": "property", "displayName": "Service Bus Type",
"group": "common", "label": "common", "required": true, "type": "object",
"javaType": "org.apache.camel.component.azure.servicebus.ServiceBusType",
"enum": [ "queue", "topic" ], "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": "queue",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration [...]
- "tokenCredential": { "kind": "property", "displayName": "Token
Credential", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.credential.TokenCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication, implemented in com.azure.id [...]
"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 [...]
"consumerOperation": { "kind": "property", "displayName": "Consumer
Operation", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusConsumerOperationDefinition",
"enum": [ "receiveMessages", "peekMessages" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "receiveMessages",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration", [...]
"disableAutoComplete": { "kind": "property", "displayName": "Disable Auto
Complete", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Disables auto-complete
and auto-abandon of received messages. By defaul [...]
- "maxAutoLockRenewDuration": { "kind": "property", "displayName": "Max Auto
Lock Renew Duration", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType": "java.time.Duration", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5min",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue auto-renewin [...]
+ "maxAutoLockRenewDuration": { "kind": "property", "displayName": "Max Auto
Lock Renew Duration", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType": "java.time.Duration", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "5m",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue auto-renewing [...]
"peekNumMaxMessages": { "kind": "property", "displayName": "Peek Num Max
Messages", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Set the max number of
messages to be peeked during the peek operation." },
- "prefetchCount": { "kind": "property", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK [...]
+ "prefetchCount": { "kind": "property", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and
{link Se [...]
"receiverAsyncClient": { "kind": "property", "displayName": "Receiver
Async Client", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the receiverAsy
[...]
"serviceBusReceiveMode": { "kind": "property", "displayName": "Service Bus
Receive Mode", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEEK_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationFie [...]
"subQueue": { "kind": "property", "displayName": "Sub Queue", "group":
"consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "com.azure.messaging.servicebus.models.SubQueue", "enum": [ "NONE",
"DEAD_LETTER_QUEUE", "TRANSFER_DEAD_LETTER_QUEUE" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the [...]
@@ -46,23 +44,23 @@
"senderAsyncClient": { "kind": "property", "displayName": "Sender Async
Client", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType":
"com.azure.messaging.servicebus.ServiceBusSenderAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets SenderAsyncClient
to [...]
"serviceBusTransactionContext": { "kind": "property", "displayName":
"Service Bus Transaction Context", "group": "producer", "label": "producer",
"required": false, "type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusTransactionContext", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Represents transaction i
[...]
"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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the connection
string for a Service Bus namespace or a specific Service Bus resource." }
+ "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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the connection
string for a Service Bus namespace or a specific Service Bus resource." },
+ "fullyQualifiedNamespace": { "kind": "property", "displayName": "Fully
Qualified Namespace", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Fully Qualified
Namespace of the service bus" },
+ "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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication, implemented in com.azure [...]
},
"properties": {
"topicOrQueueName": { "kind": "path", "displayName": "Topic Or Queue
Name", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Selected topic name or
the queue name, that is depending on serviceBusType config. For example if
service [...]
"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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the retry options
for Service Bus clients. If not specified, the defau [...]
"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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the t [...]
"clientOptions": { "kind": "parameter", "displayName": "Client Options",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.core.util.ClientOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the ClientOptions
to be sent from the client built from this builder, enabling c [...]
- "fullyQualifiedNamespace": { "kind": "parameter", "displayName": "Fully
Qualified Namespace", "group": "common", "label": "common", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Fully Qualified
Namespace of the service bus" },
"proxyOptions": { "kind": "parameter", "displayName": "Proxy Options",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.core.amqp.ProxyOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a proxy is con [...]
"serviceBusType": { "kind": "parameter", "displayName": "Service Bus
Type", "group": "common", "label": "common", "required": true, "type":
"object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusType", "enum": [
"queue", "topic" ], "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": "queue", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuratio [...]
- "tokenCredential": { "kind": "parameter", "displayName": "Token
Credential", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.credential.TokenCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication, implemented in com.azure.i [...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
"consumerOperation": { "kind": "parameter", "displayName": "Consumer
Operation", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusConsumerOperationDefinition",
"enum": [ "receiveMessages", "peekMessages" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "receiveMessages",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration" [...]
"disableAutoComplete": { "kind": "parameter", "displayName": "Disable Auto
Complete", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Disables auto-complete
and auto-abandon of received messages. By defau [...]
- "maxAutoLockRenewDuration": { "kind": "parameter", "displayName": "Max
Auto Lock Renew Duration", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType": "java.time.Duration",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"5min", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue auto-renewi [...]
+ "maxAutoLockRenewDuration": { "kind": "parameter", "displayName": "Max
Auto Lock Renew Duration", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType": "java.time.Duration",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "5m",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue auto-renewing [...]
"peekNumMaxMessages": { "kind": "parameter", "displayName": "Peek Num Max
Messages", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Set the max number of
messages to be peeked during the peek operation." },
- "prefetchCount": { "kind": "parameter", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEE [...]
+ "prefetchCount": { "kind": "parameter", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and
{link S [...]
"receiverAsyncClient": { "kind": "parameter", "displayName": "Receiver
Async Client", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the receiverAs [...]
"serviceBusReceiveMode": { "kind": "parameter", "displayName": "Service
Bus Receive Mode", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEEK_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationFi [...]
"subQueue": { "kind": "parameter", "displayName": "Sub Queue", "group":
"consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "com.azure.messaging.servicebus.models.SubQueue", "enum": [ "NONE",
"DEAD_LETTER_QUEUE", "TRANSFER_DEAD_LETTER_QUEUE" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets th [...]
@@ -74,6 +72,8 @@
"scheduledEnqueueTime": { "kind": "parameter", "displayName": "Scheduled
Enqueue Time", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "java.time.OffsetDateTime", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets OffsetDateTime at
which the message should appear in the Service Bus q [...]
"senderAsyncClient": { "kind": "parameter", "displayName": "Sender Async
Client", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType":
"com.azure.messaging.servicebus.ServiceBusSenderAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets SenderAsyncClient
to [...]
"serviceBusTransactionContext": { "kind": "parameter", "displayName":
"Service Bus Transaction Context", "group": "producer", "label": "producer",
"required": false, "type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusTransactionContext", "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Represents transaction
[...]
- "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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the connection
string for a Service Bus namespace or a specific Service Bus resource." }
+ "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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the connection
string for a Service Bus namespace or a specific Service Bus resource." },
+ "fullyQualifiedNamespace": { "kind": "parameter", "displayName": "Fully
Qualified Namespace", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Fully Qualified
Namespace of the service bus" },
+ "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.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication, implemented in com.azur [...]
}
}
diff --git
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
index f4a3673..94e488c 100644
---
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
+++
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
@@ -41,11 +41,15 @@ public class ServiceBusConfiguration implements Cloneable {
@UriPath
private String topicOrQueueName;
- @UriParam(label = "security", secret = true)
- private String connectionString;
@UriParam(label = "common", defaultValue = "queue")
@Metadata(required = true)
private ServiceBusType serviceBusType = ServiceBusType.queue;
+ @UriParam(label = "security", secret = true)
+ private String connectionString;
+ @UriParam(label = "security")
+ private String fullyQualifiedNamespace;
+ @UriParam(label = "security", secret = true)
+ private TokenCredential tokenCredential;
@UriParam(label = "common")
private ClientOptions clientOptions;
@UriParam(label = "common")
@@ -54,10 +58,6 @@ public class ServiceBusConfiguration implements Cloneable {
private AmqpRetryOptions amqpRetryOptions;
@UriParam(label = "common", defaultValue = "AMQP")
private AmqpTransportType amqpTransportType = AmqpTransportType.AMQP;
- @UriParam(label = "common")
- private String fullyQualifiedNamespace;
- @UriParam(label = "common")
- private TokenCredential tokenCredential;
@UriParam(label = "consumer", defaultValue = "receiveMessages")
private ServiceBusConsumerOperationDefinition consumerOperation =
ServiceBusConsumerOperationDefinition.receiveMessages;
@UriParam(label = "consumer")
@@ -65,13 +65,13 @@ public class ServiceBusConfiguration implements Cloneable {
private ServiceBusReceiverAsyncClient receiverAsyncClient;
@UriParam(label = "consumer")
private String subscriptionName;
- @UriParam(label = "consumer", defaultValue = "false")
+ @UriParam(label = "consumer")
private boolean disableAutoComplete;
@UriParam(label = "consumer", defaultValue = "PEEK_LOCK")
private ServiceBusReceiveMode serviceBusReceiveMode =
ServiceBusReceiveMode.PEEK_LOCK;
- @UriParam(label = "consumer", defaultValue = "5min")
+ @UriParam(label = "consumer", defaultValue = "5m")
private Duration maxAutoLockRenewDuration = Duration.ofMinutes(5);
- @UriParam(label = "consumer", defaultValue = "0")
+ @UriParam(label = "consumer")
private int prefetchCount;
@UriParam(label = "consumer")
private SubQueue subQueue;
