1

consume/egg_energy_team_assistance_consume.go

@@ -57,7 +57,7 @@ func EggEnergyTeamAssistanceConsume(queue md.MqQueue) {
 }
 
 func handleEggEnergyTeamAssistanceDataConsume(msgData []byte) error {
-	time.Sleep(time.Duration(100) * time.Millisecond) //休眠100毫秒
+	time.Sleep(time.Duration(10) * time.Millisecond) //休眠100毫秒
 	// 1.解析mq中queue的数据结构体
 	var msg *md2.EggEnergyTeamAssistanceReq
 	err := json.Unmarshal(msgData, &msg)