PlanEMQX is a prototype built on top of the EMQX message broker, enabling adaptive data exchange in IoT environments. This is achieved by (i) refining per-subscription data flows based on the applications deployed in the environment, (ii) dynamically assigning drop rates or priorities to data flows according to the requirements of the subscribing applications, and (iii) enabling the adaptation of data flows based on dynamic changes in the environment or evolving applications’ requirements. For more information about how PlanEMQX is implemented, please refer to this paper.
Implementation
You can find documentation and instructions for using PlanEMQX in this repository.