nsqclient/client.go @@ -2,13 +2,12 @@ import ( "context" "kingdee-dbapi/logger" "kingdee-dbapi/config" "kingdee-dbapi/logger" ) var producerCli Producer var consumeCli NsqConsumer func InitNsqProducer() error { var err error