Search Crosser Knowledge Base

Use the Node’s integrated MQTT Broker to share data across flows

The Node’s integrated MQTT Broker can serve as a lightweight Edge Data Hub. In addition to being exposed for external clients and applications to publish and subscribe, it can also facilitate data sharing between different flows. This approach has become a common pattern for scenarios where multiple flows need access to the same data. It helps reduce the number of direct connections to the data source while enabling gradual deployment of new use cases over time.

For example, if you want to run an AI model on live machine data while simultaneously sending data batches back to the cloud for model retraining, your setup could look like this.

Flow A:
Extract data from devices/machines/equipment, apply data model and publish to MQTT.

Flow B:
Subscribe to MQTT, create timewindow of data, run an AI model, send notification to MS Teams on event.

Flow C:
Subscribe to MQTT, create batches of data, send data back to the Cloud environment to re-train the AI model.

Crosser Tech Tips_ Node’s integrated MQTT Broker

Note: The Resource Loader module is a nice way to deploy trained AI models from the resource library without creating a new flow version.

About the author

David Nienhaus | Senior Solution Engineer

David is a Senior Solution Engineer at Crosser. He has over 15 years experience working with software integration and digitization projects for critical infrastructure.
His engineering background gives him the understanding and focus needed to solve customer use cases in the most efficient and successful way.