fix: updated README

nevernet · Mar 23, 2023 · 22ae86e · 22ae86e
1 parent 13958c7
commit 22ae86e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git 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
@@ -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
 )