in kinesis-lambda/src/main/java/com/optimize/downstream/lambda/ProcessKinesisRecords.java [79:96]
private String mergeJsonStrings(String kinJsonMessage, String addJson)
{
JSONObject kinesisJsonObject;
JSONObject addJsonObject;
kinesisJsonObject = new JSONObject(kinJsonMessage);
addJsonObject = new JSONObject(addJson);
JSONObject mergedJson = new JSONObject();
if (kinesisJsonObject.length()>0){
mergedJson = new JSONObject(kinesisJsonObject, JSONObject.getNames(kinesisJsonObject));
}
if (addJsonObject.length()>0){
for(String key : JSONObject.getNames(addJsonObject))
{
mergedJson.put(key, addJsonObject.get(key));
}
}
return mergedJson.toString();
}