diff --git a/consume/zhios_acquisition_condition.go b/consume/zhios_acquisition_condition.go index ccab4a5..0517477 100644 --- a/consume/zhios_acquisition_condition.go +++ b/consume/zhios_acquisition_condition.go @@ -26,7 +26,7 @@ func ZhiosAcquisitionCondition(queue md.MqQueue) { //1、将自己绑定到交换机上 ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) //2、取出数据进行消费 - ch.Qos(300) + ch.Qos(100) delivery := ch.Consume(queue.Name, false) var res amqp.Delivery @@ -80,9 +80,9 @@ func handleZhiosAcquisition(msg []byte) error { if eg == nil { return nil } - if canalMsg.Uid == "" { - return nil - } + //if canalMsg.Uid == "" { + // return nil + //} userInfo, _ := db.UserFindByID(eg, canalMsg.Uid) if userInfo == nil { return nil