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
---
nsq/nsq.go | 2 ++
1 files changed, 2 insertions(+), 0 deletions(-)
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