We have models running on edge devices with subscriptions (mqtt) to a central message broker (rabbit). In case of no network between the device and the central broker, esp needs to buffer messages.
Not sure how to accomplish this.
My current thoughts:
detect a failing subscription connector, through connector orchestration.
State change MQTT subscription connector from running ---> finished and act on this by starting a file/socket connection which buffers messages to a local file.
State change MQTT subscription connector from finished ----> running, act on this: read the local file and start normal operation (sending messages to a central message broker).
I don't know if this will work. Any thoughts are welcome...
Cheers,
Ebele