report/loop.go
@@ -38,7 +38,7 @@ // 测试查询请求 //sql := []byte("select * from t_icitem where FItemID=3316") //ok := nsqclient.Produce(config.Options.QueryTopic, sql) //ok := nsqclient.Produce(config.Options.SqlQueryTopic, sql) //logger.Debug("测试请求接口, %v", ok) time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second)