[camel-kamelets] 01/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch azure-storage-blob-source-pure-consumer
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 053478418a5f647665e4dbbd2f2658a2cd1651bf
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Oct 12 14:07:32 2022 +0200

    Switch Azure Storage Blob Source from timer producer style to a pure 
consumer
---
 kamelets/azure-storage-blob-source.kamelet.yaml    | 41 ++++++----------------
 .../azure-storage-blob-source.kamelet.yaml         | 41 ++++++----------------
 2 files changed, 20 insertions(+), 62 deletions(-)

diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml 
b/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
     - "camel:timer"
   template:
     from:
-      uri: "timer:azure-storage-blob-stream"
+      uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
       parameters:
-        period: "{{period}}"
+        accessKey: "{{accessKey}}"
+        credentialType: "{{credentialType}}"
       steps:
-      - to:
-          uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-          parameters:
-            operation: "listBlobs"
-            accessKey: "{{accessKey}}"
-            credentialType: "{{credentialType}}"
-      - split:
-          jsonpath: "$.*"
-          steps:
-          - set-property:
-              name: azureBlobName
-              simple: ${body.name}
-          - set-header:
-              name: CamelAzureStorageBlobBlobName
-              simple: ${exchangeProperty.azureBlobName}
-          - to:
-              uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-              parameters:
-                operation: "getBlob"
-                accessKey: "{{accessKey}}"
-          - to: "kamelet:sink"
-          - set-header:
-              name: CamelAzureStorageBlobBlobName
-              simple: ${exchangeProperty.azureBlobName}
-          - to:
-              uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-              parameters:
-                operation: "deleteBlob"
-                accessKey: "{{accessKey}}"
+        - to: "kamelet:sink"
+        - to:
+            uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+            parameters:
+              operation: "deleteBlob"
+              accessKey: "{{accessKey}}"
+              credentialType: "{{credentialType}}"
 
diff --git 
a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
     - "camel:timer"
   template:
     from:
-      uri: "timer:azure-storage-blob-stream"
+      uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
       parameters:
-        period: "{{period}}"
+        accessKey: "{{accessKey}}"
+        credentialType: "{{credentialType}}"
       steps:
-      - to:
-          uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-          parameters:
-            operation: "listBlobs"
-            accessKey: "{{accessKey}}"
-            credentialType: "{{credentialType}}"
-      - split:
-          jsonpath: "$.*"
-          steps:
-          - set-property:
-              name: azureBlobName
-              simple: ${body.name}
-          - set-header:
-              name: CamelAzureStorageBlobBlobName
-              simple: ${exchangeProperty.azureBlobName}
-          - to:
-              uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-              parameters:
-                operation: "getBlob"
-                accessKey: "{{accessKey}}"
-          - to: "kamelet:sink"
-          - set-header:
-              name: CamelAzureStorageBlobBlobName
-              simple: ${exchangeProperty.azureBlobName}
-          - to:
-              uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-              parameters:
-                operation: "deleteBlob"
-                accessKey: "{{accessKey}}"
+        - to: "kamelet:sink"
+        - to:
+            uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+            parameters:
+              operation: "deleteBlob"
+              accessKey: "{{accessKey}}"
+              credentialType: "{{credentialType}}"