[camel-kamelets] branch main updated: Azure Storage Blob Source Cloud Events Data type: Use E_TAG (#1647)

[acosentino]

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-kamelets.git


The following commit(s) were added to refs/heads/main by this push:
     new 54a1cc66 Azure Storage Blob Source Cloud Events Data type: Use E_TAG 
(#1647)
54a1cc66 is described below

commit 54a1cc6661efd3d6e2422777b85da47c652cd8ba
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Sep 19 09:40:58 2023 +0200

    Azure Storage Blob Source Cloud Events Data type: Use E_TAG (#1647)
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../azure/storage/blob/AzureStorageBlobCloudEventOutputType.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/azure/storage/blob/AzureStorageBlobCloudEventOutputType.java
 
b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/azure/storage/blob/AzureStorageBlobCloudEventOutputType.java
index ec4f5166..cbf1dd96 100644
--- 
a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/azure/storage/blob/AzureStorageBlobCloudEventOutputType.java
+++ 
b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/azure/storage/blob/AzureStorageBlobCloudEventOutputType.java
@@ -40,7 +40,7 @@ public class AzureStorageBlobCloudEventOutputType extends 
Transformer {
 
         headers.put(CloudEvents.CAMEL_CLOUD_EVENT_ID, 
message.getExchange().getExchangeId());
         headers.put(CloudEvents.CAMEL_CLOUD_EVENT_TYPE, 
"org.apache.camel.event.azure.storage.blob.getBlob");
-        headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE, 
"azure.storage.blob." + message.getHeader(BlobConstants.BLOB_NAME, 
String.class));
+        headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE, 
"azure.storage.blob." + message.getHeader(BlobConstants.E_TAG, String.class));
         headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SUBJECT, 
message.getHeader(BlobConstants.BLOB_NAME, String.class));
         headers.put(CloudEvents.CAMEL_CLOUD_EVENT_TIME, 
CloudEvents.getEventTime(message.getExchange()));
     }