Pārlūkot izejas kodu

feat:nsq 日志存储

wangshan 1 gadu atpakaļ
vecāks
revīzija
82d7efd93f
1 mainītis faili ar 1 papildinājumiem un 1 dzēšanām
  1. 1 1
      common/src/qfw/util/jy/nsq.go

+ 1 - 1
common/src/qfw/util/jy/nsq.go

@@ -53,7 +53,7 @@ func Publish(mg MongodbSim, ip, topicName, e_code, e_userid, e_app string, body
 		fmt.Println("errr2:", err)
 	}
 	producer.Stop()
-	saveLog(mg, topicName, *msg)
+	go saveLog(mg, topicName, *msg)
 	return err
 }