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()) } } }