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