浏览代码

更新

three
huangjiajun 1年前
父节点
当前提交
2195f9a5c7
共有 1 个文件被更改,包括 4 次插入4 次删除
  1. +4
    -4
      consume/zhios_acquisition_condition.go

+ 4
- 4
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


正在加载...
取消
保存