MQTT support for EventMachine