From d6b81a185f55a0322c0d404c9048cfb0a47488b9 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期一, 09 十月 2023 19:29:07 +0800
Subject: [PATCH] add log
---
main.go | 2 +-
nsq/nsq.go | 2 ++
2 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/main.go b/main.go
index 569d9c6..569c9e7 100644
--- a/main.go
+++ b/main.go
@@ -77,5 +77,5 @@
nsq.Stop()
}
- fmt.Println("clusterEvent:", stat)
+ logx.Infof("serf cluster event: %v", stat)
}
diff --git a/nsq/nsq.go b/nsq/nsq.go
index 2035f15..064efa7 100644
--- a/nsq/nsq.go
+++ b/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
})
--
Gitblit v1.8.0