queue = MqttMessageQueue()