queue = MqttMessageQueue("mytopic")