This allows the data source to get notified when a message was received at the orchestrator. I use this to save all received messages to JSON files, to compare the outputs of nodes across runs. Could also potentially be used for other purposes. Messages may have to be decoded in case of raw subscriptions, which is why the topic type is also passed to the callback.
This allows the data source to get notified when a message was received at the orchestrator. I use this to save all received messages to JSON files, to compare the outputs of nodes across runs. Could also potentially be used for other purposes. Messages may have to be decoded in case of raw subscriptions, which is why the topic type is also passed to the callback.