This flow doesn't work, because a new message object is created. If an input message contains additional properties, they are discarded.
My change transfers the properties of the input_msg to the new msg object. If input_msg is null, the new message object just contains { payload: value, topic: topic }.
This flow doesn't work, because a new message object is created. If an input message contains additional properties, they are discarded.
My change transfers the properties of the
input_msg
to the newmsg
object. Ifinput_msg
isnull
, the new message object just contains{ payload: value, topic: topic }
.