diff --git a/service/nsq/main.go b/service/nsq/main.go index cbccb3f..0a8633e 100644 --- a/service/nsq/main.go +++ b/service/nsq/main.go @@ -170,7 +170,8 @@ func main() { consumer.AddHandler(&MsgHandler{}) } - err = consumer.ConnectToNSQD("nsq.site.quack-lab.dev:41505") + url := "192.168.1.123:41505" + err = consumer.ConnectToNSQD(url) if err != nil { Error.Printf("Error connecting to nsqlookupd: %v", err) return