Update NSQD connection URL in main.go

This commit is contained in:
2025-05-21 11:34:58 +02:00
parent 114c0b909b
commit bf8815d621

View File

@@ -170,7 +170,8 @@ func main() {
consumer.AddHandler(&MsgHandler{}) 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 { if err != nil {
Error.Printf("Error connecting to nsqlookupd: %v", err) Error.Printf("Error connecting to nsqlookupd: %v", err)
return return