Commit b6c1d3db by lzzzzl

rabbit消费测试

parent 92d59b03
Showing with 8 additions and 9 deletions
......@@ -3,7 +3,6 @@ package main
import (
"flag"
"fmt"
"github.com/ichunt2019/golang-rbmq-sl/utils/rabbitmq"
"github.com/ichunt2019/logger"
"github.com/tidwall/gjson"
"golang.seo.server/collect/lxmain"
......@@ -105,14 +104,14 @@ func main() {
fmt.Println(errLx)
}
t := &RecvPro{}
go rabbitmq.Recv(rabbitmq.QueueExchange{
util.Configs.Rabbitmq_seo_log.QueueName,
util.Configs.Rabbitmq_seo_log.RoutingKey,
util.Configs.Rabbitmq_seo_log.Exchange,
util.Configs.Rabbitmq_seo_log.Type,
util.Configs.Rabbitmq_seo_log.Dns,
}, t, 3)
//t := &RecvPro{}
//go rabbitmq.Recv(rabbitmq.QueueExchange{
// util.Configs.Rabbitmq_seo_log.QueueName,
// util.Configs.Rabbitmq_seo_log.RoutingKey,
// util.Configs.Rabbitmq_seo_log.Exchange,
// util.Configs.Rabbitmq_seo_log.Type,
// util.Configs.Rabbitmq_seo_log.Dns,
//}, t, 3)
// 剩余条数
var lyRemain = function.RemainCount(util.Configs.Request_url.LyUrl, util.Configs.Request_url.LyData)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment