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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new e952e45 [create-pull-request] automated change
e952e45 is described below
commit e952e45be7aed510e863bdfd76e450b9d5c39c99
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Feb 27 01:08:53 2022 +0000
[create-pull-request] automated change
---
.../catalog/components/azure-servicebus.json | 16 +++++++-----
.../src/main/docs/azure-servicebus.json | 15 +++++++++--
.../ServiceBusComponentConfiguration.java | 29 +++++++++++++++++++++-
.../springboot/ServiceBusComponentConverter.java | 2 ++
4 files changed, 53 insertions(+), 9 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
index 3070d25..de60998 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
@@ -31,9 +31,9 @@
"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 [...]
@@ -44,7 +44,9 @@
"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": true, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "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 Ser [...]
+ "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 [...]
@@ -56,9 +58,9 @@
"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 [...]
@@ -70,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": true, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "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 Se [...]
+ "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-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
b/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
index c44902e..672e738 100644
---
a/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
+++
b/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
@@ -82,6 +82,12 @@
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
+ "name": "camel.component.azure-servicebus.fully-qualified-namespace",
+ "type": "java.lang.String",
+ "description": "Fully Qualified Namespace of the service bus",
+ "sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
+ },
+ {
"name": "camel.component.azure-servicebus.lazy-start-producer",
"type": "java.lang.Boolean",
"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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and starting the [...]
@@ -104,8 +110,7 @@
"name": "camel.component.azure-servicebus.prefetch-count",
"type": "java.lang.Integer",
"description": "Sets the prefetch count of the receiver. For both {link
ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and {link
ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} modes the default
value is 1. Prefetch speeds up the message flow by aiming to have a message
readily available for local retrieval when and before the application asks for
one using ServiceBusReceiverAsyncClient#receiveMessages(). Setting a non-zero
value will prefetch that number of messages. Sett [...]
- "sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration",
- "defaultValue": 0
+ "sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
"name": "camel.component.azure-servicebus.producer-operation",
@@ -166,6 +171,12 @@
"type": "java.lang.String",
"description": "Sets the name of the subscription in the topic to listen
to. topicOrQueueName and serviceBusType=topic must also be set.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
+ },
+ {
+ "name": "camel.component.azure-servicebus.token-credential",
+ "type": "com.azure.core.credential.TokenCredential",
+ "description": "A TokenCredential for Azure AD authentication,
implemented in com.azure.identity. The option is a
com.azure.core.credential.TokenCredential type.",
+ "sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
}
],
"hints": []
diff --git
a/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
b/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
index 2c482c3..f22a471 100644
---
a/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
+++
b/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
@@ -22,6 +22,7 @@ import javax.annotation.Generated;
import com.azure.core.amqp.AmqpRetryOptions;
import com.azure.core.amqp.AmqpTransportType;
import com.azure.core.amqp.ProxyOptions;
+import com.azure.core.credential.TokenCredential;
import com.azure.core.util.ClientOptions;
import com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient;
import com.azure.messaging.servicebus.ServiceBusSenderAsyncClient;
@@ -132,7 +133,7 @@ public class ServiceBusComponentConfiguration
* will prefetch that number of messages. Setting the value to zero turns
* prefetch off.
*/
- private Integer prefetchCount = 0;
+ private Integer prefetchCount;
/**
* Sets the receiverAsyncClient in order to consume messages in the
* Consumer. The option is a
@@ -197,6 +198,16 @@ public class ServiceBusComponentConfiguration
* Service Bus resource.
*/
private String connectionString;
+ /**
+ * Fully Qualified Namespace of the service bus
+ */
+ private String fullyQualifiedNamespace;
+ /**
+ * A TokenCredential for Azure AD authentication, implemented in
+ * com.azure.identity. The option is a
+ * com.azure.core.credential.TokenCredential type.
+ */
+ private TokenCredential tokenCredential;
public AmqpRetryOptions getAmqpRetryOptions() {
return amqpRetryOptions;
@@ -387,4 +398,20 @@ public class ServiceBusComponentConfiguration
public void setConnectionString(String connectionString) {
this.connectionString = connectionString;
}
+
+ public String getFullyQualifiedNamespace() {
+ return fullyQualifiedNamespace;
+ }
+
+ public void setFullyQualifiedNamespace(String fullyQualifiedNamespace) {
+ this.fullyQualifiedNamespace = fullyQualifiedNamespace;
+ }
+
+ public TokenCredential getTokenCredential() {
+ return tokenCredential;
+ }
+
+ public void setTokenCredential(TokenCredential tokenCredential) {
+ this.tokenCredential = tokenCredential;
+ }
}
\ No newline at end of file
diff --git
a/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConverter.java
b/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConverter.java
index 7477b88..627be00 100644
---
a/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConverter.java
+++
b/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConverter.java
@@ -50,6 +50,7 @@ public class ServiceBusComponentConverter implements
GenericConverter {
answer.add(new ConvertiblePair(String.class,
java.time.OffsetDateTime.class));
answer.add(new ConvertiblePair(String.class,
com.azure.messaging.servicebus.ServiceBusSenderAsyncClient.class));
answer.add(new ConvertiblePair(String.class,
com.azure.messaging.servicebus.ServiceBusTransactionContext.class));
+ answer.add(new ConvertiblePair(String.class,
com.azure.core.credential.TokenCredential.class));
return answer;
}
@@ -75,6 +76,7 @@ public class ServiceBusComponentConverter implements
GenericConverter {
case "java.time.OffsetDateTime": return
applicationContext.getBean(ref, java.time.OffsetDateTime.class);
case "com.azure.messaging.servicebus.ServiceBusSenderAsyncClient":
return applicationContext.getBean(ref,
com.azure.messaging.servicebus.ServiceBusSenderAsyncClient.class);
case
"com.azure.messaging.servicebus.ServiceBusTransactionContext": return
applicationContext.getBean(ref,
com.azure.messaging.servicebus.ServiceBusTransactionContext.class);
+ case "com.azure.core.credential.TokenCredential": return
applicationContext.getBean(ref,
com.azure.core.credential.TokenCredential.class);
}
return null;
}
