diff --git a/notification-core/src/main/java/org/opengroup/osdu/notification/service/SubscriptionHandler.java b/notification-core/src/main/java/org/opengroup/osdu/notification/service/SubscriptionHandler.java index 4df5aa6eaa2eb1f36bb67ed6d683fa626d889a05..40716ff81188fc96d4df5804256810a146d8262c 100644 --- a/notification-core/src/main/java/org/opengroup/osdu/notification/service/SubscriptionHandler.java +++ b/notification-core/src/main/java/org/opengroup/osdu/notification/service/SubscriptionHandler.java @@ -73,6 +73,9 @@ public class SubscriptionHandler { while (itr.hasNext()) { System.out.println(itr.next()); } + tempheaders.entrySet().forEach(entry -> { + System.out.println(entry.getKey() + " " + entry.getValue()); + }); System.out.println("**********TESTING ISTIO PRINTING ALL HEADERS done*************"); ISubscriptionService service = subscriptionFactory.create(headers); 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 bc731b0ff24ce395e6ec2ac528597e6f57f5eb32..73867657ffeb7afca192d02e38acd60c84e0508f 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,6 +112,7 @@ 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")); content.setAttributes(lowerCase); String decoded = new String(Base64.getDecoder().decode(data));