From 87be86be082d27234412de7ffacbe5670c521bf8 Mon Sep 17 00:00:00 2001 From: Bo-Yi Wu Date: Sat, 17 Jul 2021 20:22:39 +0800 Subject: [PATCH] chore(NSQ): update connect method to ConnectToNSQD Signed-off-by: Bo-Yi Wu --- queue/nsq/nsq.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/queue/nsq/nsq.go b/queue/nsq/nsq.go index b6c7fbe..5c44ddf 100644 --- a/queue/nsq/nsq.go +++ b/queue/nsq/nsq.go @@ -87,7 +87,7 @@ func (s *Worker) BeforeRun() error { func (s *Worker) AfterRun() error { s.once.Do(func() { time.Sleep(100 * time.Millisecond) - err := s.q.ConnectToNSQLookupd(s.addr) + err := s.q.ConnectToNSQD(s.addr) if err != nil { panic("Could not connect nsq server: " + err.Error()) }