Concatenates multiple messages based on a list of topics;
- Topics (List of objects) List of objects as guidance for concatenation
- Topic (String) Expected topics
- Mandatory (Mandatory/Optional) The message will not be emitted through output if one of the mandatory topics is missing
Multiple messages that contains topic and payload
A message with all received topics as key and their payloads as values If multiple meessages will have the same topic, the last message will be considered The output message will be emitted when the last mandatory topic arrives. If there are no mandatory topics then will be emitted when all optional topics are received.
- Adding Join by Topics;
[{"id":"e46f3c73.cf7c","type":"tab","label":"Flow 2","disabled":false,"info":""},{"id":"37c0e705.96c6b8","type":"join-topics","z":"e46f3c73.cf7c","name":"Join","topics":[{"topic":"a","mandatory":false},{"topic":"b","mandatory":true},{"topic":"c","mandatory":false}],"x":410,"y":120,"wires":[["8be67450.049df8"]]},{"id":"bb62ca89.aac188","type":"inject","z":"e46f3c73.cf7c","name":"","topic":"a","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":210,"y":80,"wires":[["37c0e705.96c6b8"]]},{"id":"4b0e0dde.f4f554","type":"inject","z":"e46f3c73.cf7c","name":"","topic":"b","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":210,"y":120,"wires":[["37c0e705.96c6b8"]]},{"id":"8be67450.049df8","type":"debug","z":"e46f3c73.cf7c","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","x":530,"y":120,"wires":[]},{"id":"e28ebc44.1cc6f","type":"inject","z":"e46f3c73.cf7c","name":"","topic":"c","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":210,"y":160,"wires":[["37c0e705.96c6b8"]]},{"id":"3036280f.7b5b78","type":"inject","z":"e46f3c73.cf7c","name":"","topic":"d","payload":"","payloadType":"date","repeat":"","crontab":"","once":false,"onceDelay":0.1,"x":210,"y":200,"wires":[["37c0e705.96c6b8"]]}]