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())
 		}