Skip to main content

PlanEMQX: AI-enabled Message Broker

Overview of the PlanIoT prototype

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.

PlanEMQX is deployed using the Mininet network emulator. The PDDL modelling language is then used to define domain and problem files used by AI Planning. PlanEMQX relies on the Metric-FF planner to generate configuration plans for IoT infrastructures.

To create data flows per-subscription, PlanEMQX leverages EMQX’s Authentication API and applies the following process:

Overview of the PlanEMQX subscription process

To define priorites per data flow, PlanEMQX follows the process below:

Overview of the PlanEMQX priorities workflow