queue := mqttqueue.NewMqttMessageQueue("mytopic")