Rules engine for processing MQTT event streams and re-broadcasting them for consumption - View it on GitHub