This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch azure-storage-blob-ce in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit fb674b34e2230f9c838281659dd0b5d335804416 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Sep 19 09:31:36 2023 +0200 Azure Storage Blob Source Cloud Events Data type: Use E_TAG Signed-off-by: Andrea Cosentino <[email protected]> --- .../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())); }
