x

2 years ago · ff30f8dfc4
parent 9291e6faf9
commit ff30f8dfc4
1 changed files with 1 additions and 1 deletions
--- a/log/mq/nsq.go
+++ b/log/mq/nsq.go
@ -53,7 +53,7 @@ func (s *nsqLogger) Name() string {
 	return "app_log"
 }

-func NewNsqLogger(host string, topic string) log.Logger {
+func NewNsqLogger(host string, topic string) *nsqLogger {
 	client, err := nsq.NewProducer(host, nsq.NewConfig())
 	if err != nil {
 		panic(err)