This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/main by this push:
new 5c9129aab7 Use RAW for Azure EventHubs / ServiceBus connectionString
and accessKey as it can contains special characters
5c9129aab7 is described below
commit 5c9129aab7c6d2a518b5128ccad30c9d4d7a211f
Author: Lukas Lowinger <[email protected]>
AuthorDate: Fri Sep 5 09:37:18 2025 +0200
Use RAW for Azure EventHubs / ServiceBus connectionString and accessKey as
it can contains special characters
---
.../azure/eventhubs/it/AzureEventhubsRoutes.java | 30 +++++++++++-----------
.../azure/servicebus/it/AzureServiceBusRoutes.java | 12 ++++-----
2 files changed, 21 insertions(+), 21 deletions(-)
diff --git
a/integration-test-groups/azure/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsRoutes.java
b/integration-test-groups/azure/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsRoutes.java
index 3238fe75ca..a9131c8ae1 100644
---
a/integration-test-groups/azure/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsRoutes.java
+++
b/integration-test-groups/azure/azure-eventhubs/src/main/java/org/apache/camel/quarkus/component/azure/eventhubs/it/AzureEventhubsRoutes.java
@@ -63,9 +63,9 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
// Consumes EventHub messages and routes them based on which
partition they are associated with
from(azureEventhubs("")
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() + ")")
.blobAccountName(azureStorageAccountName)
- .blobAccessKey(azureStorageAccountKey)
+ .blobAccessKey("RAW(" + azureStorageAccountKey + ")")
.blobContainerName(azureBlobContainerName.get()))
.routeId("eventhubs-consumer")
.autoStartup(false)
@@ -80,7 +80,7 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
// Consumes events from partition 2 with InMemoryCheckpointStore
from(azureEventhubs("")
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() + ")")
.checkpointStore(new InMemoryCheckpointStore()))
.routeId("eventhubs-consumer-custom-checkpoint-store")
.autoStartup(false)
@@ -93,7 +93,7 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
// Reads all events sent to partition 2 from the beginning
from(azureEventhubs("")
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() + ")")
.checkpointStore(new InMemoryCheckpointStore())
.eventPosition(Map.of("2", EventPosition.earliest())))
.routeId("eventhubs-consumer-with-event-position")
@@ -110,7 +110,7 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
.credentialType(CredentialType.TOKEN_CREDENTIAL)
.tokenCredential(tokenCredential)
.blobAccountName(azureStorageAccountName)
- .blobAccessKey(azureStorageAccountKey)
+ .blobAccessKey("RAW(" + azureStorageAccountKey + ")")
.blobContainerName(azureBlobContainerName.get()))
.routeId("eventhubs-consumer-custom-token-credential")
.autoStartup(false)
@@ -123,9 +123,9 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
// Consumes events from partition 4 using WS transport
from(azureEventhubs("")
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() + ")")
.blobAccountName(azureStorageAccountName)
- .blobAccessKey(azureStorageAccountKey)
+ .blobAccessKey("RAW(" + azureStorageAccountKey + ")")
.blobContainerName(azureBlobContainerName.get())
.amqpTransportType(AmqpTransportType.AMQP_WEB_SOCKETS))
.routeId("eventhubs-consumer-with-amqp-ws-transport")
@@ -138,11 +138,11 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
from("direct:sendEvent")
.to(azureEventhubs("")
- .connectionString(connectionString.get()));
+ .connectionString("RAW(" + connectionString.get()
+ ")"));
from("direct:sendEventUsingAmqpWebSockets")
.to(azureEventhubs("")
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get()
+ ")")
.amqpTransportType(AmqpTransportType.AMQP_WEB_SOCKETS));
from("direct:sendEventUsingTokenCredential")
@@ -152,9 +152,9 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
// Consumes EventHub messages that are produced by the custom
client in direct:sendEventUsingCustomClient
from(azureEventhubs("")
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() + ")")
.blobAccountName(azureStorageAccountName)
- .blobAccessKey(azureStorageAccountKey)
+ .blobAccessKey("RAW(" + azureStorageAccountKey + ")")
.blobContainerName(azureBlobContainerName.get()))
.routeId("eventhubs-consumer-for-custom-client")
.autoStartup(false)
@@ -172,9 +172,9 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
// Consumes using an auto-generated connection string from the
shared access configuration
from(azureEventhubs(eventHubsPath)
.sharedAccessName(connectionProperties.get("SharedAccessKey"))
-
.sharedAccessKey(connectionProperties.get("SharedAccessKeyValue"))
+ .sharedAccessKey("RAW(" +
connectionProperties.get("SharedAccessKeyValue") + ")")
.blobAccountName(azureStorageAccountName)
- .blobAccessKey(azureStorageAccountKey)
+ .blobAccessKey("RAW(" + azureStorageAccountKey + ")")
.blobContainerName(azureBlobContainerName.get()))
.routeId("eventhubs-consumer-generated-connection-string")
.autoStartup(false)
@@ -188,14 +188,14 @@ public class AzureEventhubsRoutes extends
EndpointRouteBuilder {
from("direct:sendEventWithGeneratedConnectionString")
.to(azureEventhubs(eventHubsPath)
.sharedAccessName(connectionProperties.get("SharedAccessKey"))
-
.sharedAccessKey(connectionProperties.get("SharedAccessKeyValue")));
+ .sharedAccessKey("RAW(" +
connectionProperties.get("SharedAccessKeyValue") + ")"));
if (AzureCredentialsHelper.isAzureIdentityCredentialsAvailable()) {
// Consumes events from partition 4 using AZURE_IDENTITY
credential type
from(azureEventhubs(eventHubsPath)
.credentialType(CredentialType.AZURE_IDENTITY)
.blobAccountName(azureStorageAccountName)
- .blobAccessKey(azureStorageAccountKey)
+ .blobAccessKey("RAW(" + azureStorageAccountKey + ")")
.blobContainerName(azureBlobContainerName.get()))
.routeId("eventhubs-consumer-azure-identity-credential")
.autoStartup(false)
diff --git
a/integration-test-groups/azure/azure-servicebus/src/main/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusRoutes.java
b/integration-test-groups/azure/azure-servicebus/src/main/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusRoutes.java
index 9dc232196a..4c25e54290 100644
---
a/integration-test-groups/azure/azure-servicebus/src/main/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusRoutes.java
+++
b/integration-test-groups/azure/azure-servicebus/src/main/java/org/apache/camel/quarkus/component/azure/servicebus/it/AzureServiceBusRoutes.java
@@ -58,14 +58,14 @@ public class AzureServiceBusRoutes extends
EndpointRouteBuilder {
// Simple queue consumer
from(azureServicebus(queueName.get())
- .connectionString(connectionString.get()))
+ .connectionString("RAW(" + connectionString.get() + ")"))
.routeId("servicebus-queue-consumer-" +
AmqpTransportType.AMQP)
.autoStartup(false)
.toD(mock(mockEndpointUri));
// Consume from queue with web socket transport
from(azureServicebus(queueName.get())
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() + ")")
.amqpTransportType(AmqpTransportType.AMQP_WEB_SOCKETS))
.autoStartup(false)
.routeId("servicebus-queue-consumer-" +
AmqpTransportType.AMQP_WEB_SOCKETS)
@@ -89,7 +89,7 @@ public class AzureServiceBusRoutes extends
EndpointRouteBuilder {
// Queue consumer for scheduled messages
from(azureServicebus(queueName.get())
- .connectionString(connectionString.get()))
+ .connectionString("RAW(" + connectionString.get() + ")"))
.routeId("servicebus-queue-scheduled-consumer")
.autoStartup(false)
.to("mock:servicebus-queue-scheduled-consumer-results");
@@ -99,7 +99,7 @@ public class AzureServiceBusRoutes extends
EndpointRouteBuilder {
from(azureServicebus(topicName.get())
.serviceBusType(ServiceBusType.topic)
.subscriptionName(topicSubscriptionName.get())
- .connectionString(connectionString.get()))
+ .connectionString("RAW(" + connectionString.get() +
")"))
.routeId("servicebus-topic-consumer-" +
AmqpTransportType.AMQP)
.autoStartup(false)
.toD(mock(mockEndpointUri));
@@ -108,7 +108,7 @@ public class AzureServiceBusRoutes extends
EndpointRouteBuilder {
from(azureServicebus(topicName.get())
.serviceBusType(ServiceBusType.topic)
.subscriptionName(topicSubscriptionName.get())
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get() +
")")
.amqpTransportType(AmqpTransportType.AMQP_WEB_SOCKETS))
.autoStartup(false)
.routeId("servicebus-topic-consumer-" +
AmqpTransportType.AMQP_WEB_SOCKETS)
@@ -137,7 +137,7 @@ public class AzureServiceBusRoutes extends
EndpointRouteBuilder {
// Produce scheduled messages
from(direct("scheduled"))
.to(azureServicebus(queueName.get())
- .connectionString(connectionString.get())
+ .connectionString("RAW(" + connectionString.get()
+ ")")
.producerOperation("scheduleMessages"));
if (AzureServiceBusHelper.isAzureIdentityCredentialsAvailable()) {
