From 22ae86e3af1207d924ad4c990b607e4aee05d952 Mon Sep 17 00:00:00 2001 From: Daniel Qin Date: Thu, 23 Mar 2023 17:04:55 +0800 Subject: [PATCH] fix: updated README --- README.md | 6 +++--- go.mod | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/README.md b/README.md index ed7eec8..bd82fe0 100644 --- a/README.md +++ b/README.md @@ -17,10 +17,10 @@ func main() { runtime.GOMAXPROCS(runtime.NumCPU()) - producer := nsqworker.NewNsqProducer(conf.Nsq.Addr, nsq.NewConfig()) + producer := nsqworker.NewProducer(conf.Nsq.Addr, nsq.NewConfig()) logger.Info("nsq producer initialized.") - nsqConfig := nsqworker.NewNsqConsumerConfig(conf.Nsq.Addr, conf.Nsq.LookupdAddr, conf.Nsq.Topic, conf.Nsq.ConsumerCount) - consumer := nsqworker.NewNsqConsumer(nsqConfig, nsq.NewConfig()) + nsqConfig := nsqworker.NewConfig(conf.Nsq.Addr, conf.Nsq.LookupdAddr, conf.Nsq.Topic, conf.Nsq.ConsumerCount) + consumer := nsqworker.NewConsumer(nsqConfig, nsq.NewConfig()) logger.Info("nsq consumer initialized.") exitChan := make(chan struct{}) diff --git a/go.mod b/go.mod index 7b45e7d..653fe05 100644 --- a/go.mod +++ b/go.mod @@ -8,7 +8,7 @@ require ( ) require ( - github.com/astaxie/beego v1.12.1 // indirect - github.com/golang/snappy v0.0.1 // indirect - github.com/shiena/ansicolor v0.0.0-20151119151921-a422bbe96644 // indirect + github.com/astaxie/beego v1.12.3 // indirect + github.com/golang/snappy v0.0.4 // indirect + github.com/shiena/ansicolor v0.0.0-20200904210342-c7312218db18 // indirect )