zhangzengfei
2023-08-11 742923a5512707bdfd4c0e2e9adfcb86b453be28
nsqclient/client.go
@@ -3,8 +3,8 @@
import (
   "context"
   "kingdee-dbapi/config"
   "kingdee-dbapi/logger"
   "plc-recorder/config"
   "plc-recorder/logger"
)
var producerCli Producer
@@ -45,6 +45,5 @@
      if err := c.Run(config.Options.NsqServer, 1); err != nil {
         logger.Error("运行nsq消费客户端失败, %s", err.Error())
      }
   }
}