in amazon-sns-trigger-server/src/main/java/jetbrains/buildServer/clouds/amazon/sns/trigger/service/SnsBuildTriggeringPolicy.java [34:52]
private Map<String, String> customizeWithSnsMessageData(@NotNull SnsNotificationDto latestSnsMessage) {
Map<String, String> result = new HashMap<>();
if (latestSnsMessage.getSubject() != null) {
result.put(AwsSnsTriggerConstants.SNS_MESSAGE_SUBJECT_PARAMETER_PLACEHOLDER, latestSnsMessage.getSubject());
}
if (latestSnsMessage.getMessage() != null) {
result.put(AwsSnsTriggerConstants.SNS_MESSAGE_BODY_PARAMETER_PLACEHOLDER, latestSnsMessage.getMessage());
}
if (latestSnsMessage.getAttributes() != null) {
latestSnsMessage.getAttributes().forEach((key, value) -> {
String stringValue = (String) ((Map<String, Object>) value).get("Value");
result.put(AwsSnsTriggerConstants.SNS_MESSAGE_ATTRIBUTES_PARAMETER_PLACEHOLDER + key, stringValue);
});
}
return result;
}