|
|
|
@ -161,7 +161,7 @@ public class TbMsgDeDuplicateNode implements TbNode { |
|
|
|
msgs.forEach(msg -> { |
|
|
|
ObjectNode msgNode = JacksonUtil.newObjectNode(); |
|
|
|
msgNode.set("msg", JacksonUtil.toJsonNode(msg.getData())); |
|
|
|
msgNode.set("metadata", JacksonUtil.valueToTree(msg.getMetaData())); |
|
|
|
msgNode.set("metadata", JacksonUtil.valueToTree(msg.getMetaData().getData())); |
|
|
|
mergedData.add(msgNode); |
|
|
|
}); |
|
|
|
return JacksonUtil.toString(mergedData); |
|
|
|
|