diff --git a/provider/notification-aws/src/main/java/org/opengroup/osdu/notification/provider/aws/impl/AwsPubsubRequestBodyExtractor.java b/provider/notification-aws/src/main/java/org/opengroup/osdu/notification/provider/aws/impl/AwsPubsubRequestBodyExtractor.java
index 73867657ffeb7afca192d02e38acd60c84e0508f..7b34cb98bb48720e4bb3fdfac1e52efdc9258bc3 100644
--- a/provider/notification-aws/src/main/java/org/opengroup/osdu/notification/provider/aws/impl/AwsPubsubRequestBodyExtractor.java
+++ b/provider/notification-aws/src/main/java/org/opengroup/osdu/notification/provider/aws/impl/AwsPubsubRequestBodyExtractor.java
@@ -112,7 +112,9 @@ public class AwsPubsubRequestBodyExtractor implements IPubsubRequestBodyExtracto
             throw new AppException(HttpStatus.BAD_REQUEST.value(), INVALID_PUBSUB_MESSAGE,
                     "No tenant information from pubsub message.");
         }
-        lowerCase.put("x-user-id",attributes.get("x-user-id"));
+         String x_user_id= request.getHeader("x-user-id");
+        System.out.println("*******x_user_id from original request****=="+x_user_id);
+        lowerCase.put("x-user-id",x_user_id);
         content.setAttributes(lowerCase);
 
         String decoded = new String(Base64.getDecoder().decode(data));