From 715c65be72c9847f47bd94af3c8677ff4c741619 Mon Sep 17 00:00:00 2001
From: Yunhua Koglin <kogliny@amazon.com>
Date: Fri, 7 Mar 2025 14:09:37 -0600
Subject: [PATCH] fix sns

---
 .../schema/provider/aws/impl/messagebus/MessageBusImpl.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/provider/schema-aws/src/main/java/org/opengroup/osdu/schema/provider/aws/impl/messagebus/MessageBusImpl.java b/provider/schema-aws/src/main/java/org/opengroup/osdu/schema/provider/aws/impl/messagebus/MessageBusImpl.java
index 437940396..12acfd212 100644
--- a/provider/schema-aws/src/main/java/org/opengroup/osdu/schema/provider/aws/impl/messagebus/MessageBusImpl.java
+++ b/provider/schema-aws/src/main/java/org/opengroup/osdu/schema/provider/aws/impl/messagebus/MessageBusImpl.java
@@ -99,6 +99,8 @@ public class MessageBusImpl implements IMessageBus {
         headersMap.put(DpsHeaders.ACCOUNT_ID, tenant);
         headersMap.put(DpsHeaders.DATA_PARTITION_ID, tenant);
         headersMap.put(DpsHeaders.CORRELATION_ID, headers.getCorrelationId());
+        headersMap.put(DpsHeaders.USER_EMAIL, headers.getUserEmail());
+        headersMap.put(DpsHeaders.AUTHORIZATION, headers.getAuthorization());
         return DpsHeaders.createFromMap(headersMap);
     }
 
-- 
GitLab