Reimplement the current `flow_store` feature based on NATS
Reimplement the current
flow_storefeature based on NATS