(camel) branch main updated: CAMEL-24159: camel-azure-storage-queue - Fix medium-severity bugs from code review (#24870)

[davsclaus]

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


The following commit(s) were added to refs/heads/main by this push:
     new 21b8be5aa494 CAMEL-24159: camel-azure-storage-queue - Fix 
medium-severity bugs from code review (#24870)
21b8be5aa494 is described below

commit 21b8be5aa494291c2b83da1615c718ee8df60ef4
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Jul 18 07:29:34 2026 +0200

    CAMEL-24159: camel-azure-storage-queue - Fix medium-severity bugs from code 
review (#24870)
    
    CAMEL-24159: camel-azure-storage-queue - Fix medium-severity bugs from code 
review
    
    Co-Authored-By: Claude Opus 4.6 <nore...@anthropic.com>
    
    Signed-off-by: Claus Ibsen <davscl...@apache.org>
---
 .../apache/camel/component/azure/storage/queue/QueueComponent.java    | 4 +++-
 .../component/azure/storage/queue/client/QueueClientWrapper.java      | 4 ++++
 .../component/azure/storage/queue/operations/QueueOperations.java     | 4 +++-
 3 files changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueComponent.java
 
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueComponent.java
index 2b5ef99497f6..92c5a4dbf7b9 100644
--- 
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueComponent.java
+++ 
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueComponent.java
@@ -73,7 +73,9 @@ public class QueueComponent extends HealthCheckComponent {
                     
configuration.setCredentialType(CredentialType.SHARED_ACCOUNT_KEY);
                 }
             } else {
-                
configuration.setCredentialType(CredentialType.SHARED_KEY_CREDENTIAL);
+                if (configuration.getCredentialType() == null) {
+                    
configuration.setCredentialType(CredentialType.SHARED_KEY_CREDENTIAL);
+                }
             }
         }
 
diff --git 
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java
 
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java
index 76aa15f4a5d2..55687917fd03 100644
--- 
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java
+++ 
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java
@@ -43,6 +43,10 @@ public class QueueClientWrapper {
         return client.createWithResponse(metadata, timeout, Context.NONE);
     }
 
+    public void createIfNotExists(Map<String, String> metadata, Duration 
timeout) {
+        client.createIfNotExistsWithResponse(metadata, timeout, Context.NONE);
+    }
+
     public Response<Void> delete(Duration timeout) {
         return client.deleteWithResponse(timeout, Context.NONE);
     }
diff --git 
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/operations/QueueOperations.java
 
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/operations/QueueOperations.java
index c285f5c329ea..09c324a936ab 100644
--- 
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/operations/QueueOperations.java
+++ 
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/operations/QueueOperations.java
@@ -82,7 +82,9 @@ public class QueueOperations {
         final boolean queueCreated = 
configurationOptionsProxy.isCreateQueue(exchange);
 
         if (queueCreated) {
-            createQueue(exchange);
+            final Map<String, String> metadata = 
configurationOptionsProxy.getMetadata(exchange);
+            final Duration timeout = 
configurationOptionsProxy.getTimeout(exchange);
+            client.createIfNotExists(metadata, timeout);
         }
 
         final String text = exchange.getIn().getBody(String.class);