Skip to content
Snippets Groups Projects
Commit 00cc8611 authored by Rucha Deshpande's avatar Rucha Deshpande
Browse files

add x-user-id to pubsubbodyextractor

parent e3b62528
No related branches found
No related tags found
1 merge request!137Aws xuserid fix
...@@ -73,6 +73,9 @@ public class SubscriptionHandler { ...@@ -73,6 +73,9 @@ public class SubscriptionHandler {
while (itr.hasNext()) { while (itr.hasNext()) {
System.out.println(itr.next()); 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*************"); System.out.println("**********TESTING ISTIO PRINTING ALL HEADERS done*************");
ISubscriptionService service = subscriptionFactory.create(headers); ISubscriptionService service = subscriptionFactory.create(headers);
......
...@@ -112,6 +112,7 @@ public class AwsPubsubRequestBodyExtractor implements IPubsubRequestBodyExtracto ...@@ -112,6 +112,7 @@ public class AwsPubsubRequestBodyExtractor implements IPubsubRequestBodyExtracto
throw new AppException(HttpStatus.BAD_REQUEST.value(), INVALID_PUBSUB_MESSAGE, throw new AppException(HttpStatus.BAD_REQUEST.value(), INVALID_PUBSUB_MESSAGE,
"No tenant information from pubsub message."); "No tenant information from pubsub message.");
} }
lowerCase.put("x-user-id",attributes.get("x-user-id"));
content.setAttributes(lowerCase); content.setAttributes(lowerCase);
String decoded = new String(Base64.getDecoder().decode(data)); String decoded = new String(Base64.getDecoder().decode(data));
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment