add log

zhangqian

2023-10-09 d6b81a185f55a0322c0d404c9048cfb0a47488b9

add log

 main.go

@@ -77,5 +77,5 @@
        nsq.Stop()
    }

    fmt.Println("clusterEvent:", stat)
    logx.Infof("serf cluster event: %v", stat)
}

 nsq/nsq.go

@@ -74,12 +74,14 @@
            }
        }
    })
    logx.Infof("add consumer success, topic:%v", topic)
}

func (c *consumerManager) stop() {
    c.clients.Range(func(key, value any) bool {
        if consumer, ok := value.(*nsqclient.NsqConsumer); ok {
            nsqclient.DestroyNsqConsumer(consumer)
            logx.Infof("try stop consumer, topic : %v", key)
        }
        return true
    })