From 577dfc89748ba4718b1f195a6085f5f965d81cae Mon Sep 17 00:00:00 2001 From: voltgizerz Date: Sat, 2 Sep 2023 19:16:52 +0700 Subject: [PATCH 1/2] Add comment --- config/nsq.go | 1 + 1 file changed, 1 insertion(+) diff --git a/config/nsq.go b/config/nsq.go index 71e57e6..19a1faf 100644 --- a/config/nsq.go +++ b/config/nsq.go @@ -93,6 +93,7 @@ type Consumer struct { Client *nsq.Consumer } +// NewConsumer - function. func NewConsumer(addr, channel, topicName string) *Consumer { // Instantiate a consumer that will subscribe to the provided channel. config := nsq.NewConfig() From 7ac63b2228a9c8e6446868de915583e850d60039 Mon Sep 17 00:00:00 2001 From: voltgizerz Date: Sat, 2 Sep 2023 19:17:20 +0700 Subject: [PATCH 2/2] Add comment --- config/nsq.go | 1 + 1 file changed, 1 insertion(+) diff --git a/config/nsq.go b/config/nsq.go index 19a1faf..9a65f08 100644 --- a/config/nsq.go +++ b/config/nsq.go @@ -89,6 +89,7 @@ func (h *Message) HandleMessage(m *nsq.Message) error { return err } +// Consumer type Consumer struct { Client *nsq.Consumer }