修改bug

mqtt_binding/mqtt_client/mqtt_client.go

@@ -269,6 +269,7 @@ func (c *MqttClient) subscribeRoutine() {
 	for {
 		select {
 		case <-c.subscribeDoneChan:
+			return
 		case payload := <-c.subscribeChan:
 			payload.item.CallHandlers(payload.payload)
 		}