debug 日志打点

qlinhz · qlinhz · commit c7fba85b9324 · 2024-08-29T22:45:35.000+08:00
diff --git a/message/router.go b/message/router.go
@@ -613,19 +613,19 @@ func (h *handler) run(ctx context.Context, middlewares []middleware) {
 	go h.handleClose(ctx)
 
 	for msg := range h.messagesCh {
-		h.logger.Info("GoChannel #8", watermill.LogFields{
+		h.logger.Trace("GoChannel #8", watermill.LogFields{
 			"subscriber_name": h.name,
 			"topic":           h.subscribeTopic,
 		})
 		h.runningHandlersWgLock.Lock()
-		h.logger.Info("GoChannel #9", watermill.LogFields{
+		h.logger.Trace("GoChannel #9", watermill.LogFields{
 			"subscriber_name": h.name,
 			"topic":           h.subscribeTopic,
 		})
 		h.runningHandlersWg.Add(1)
 		h.runningHandlersWgLock.Unlock()
 
-		h.logger.Info("GoChannel #10", watermill.LogFields{
+		h.logger.Trace("GoChannel #10", watermill.LogFields{
 			"subscriber_name": h.name,
 			"topic":           h.subscribeTopic,
 		})
@@ -771,7 +771,7 @@ func (h *handler) handleMessage(msg *Message, handler HandlerFunc) {
 	defer h.runningHandlersWg.Done()
 	msgFields := watermill.LogFields{"message_uuid": msg.UUID}
 
-	h.logger.Info("GoChannel #11", msgFields)
+	h.logger.Trace("GoChannel #11", msgFields)
 	defer func() {
 		if recovered := recover(); recovered != nil {
 			h.logger.Error(
diff --git a/pubsub/gochannel/pubsub.go b/pubsub/gochannel/pubsub.go
@@ -147,17 +147,17 @@ func (g *GoChannel) sendMessage(topic string, message *message.Message) (<-chan
 	}
 
 	go func(subscribers []*subscriber) {
-		g.logger.Info("GoChannel #1", logFields)
+		g.logger.Trace("GoChannel #1", logFields)
 		wg := &sync.WaitGroup{}
 
 		for i := range subscribers {
 			subscriber := subscribers[i]
 
-			g.logger.Info("GoChannel #2", logFields)
+			g.logger.Trace("GoChannel #2", logFields)
 
 			wg.Add(1)
 			go func() {
-				g.logger.Info("GoChannel #3", logFields)
+				g.logger.Trace("GoChannel #3", logFields)
 				subscriber.sendMessageToSubscriber(message, logFields)
 				wg.Done()
 			}()
@@ -346,19 +346,19 @@ func (s *subscriber) Close() {
 
 func (s *subscriber) sendMessageToSubscriber(msg *message.Message, logFields watermill.LogFields) {
 
-	s.logger.Info("GoChannel #4", logFields)
+	s.logger.Trace("GoChannel #4", logFields)
 
 	s.sending.Lock()
 	defer s.sending.Unlock()
 
-	s.logger.Info("GoChannel #5", logFields)
+	s.logger.Trace("GoChannel #5", logFields)
 
 	ctx, cancelCtx := context.WithCancel(s.ctx)
 	defer cancelCtx()
 
 SendToSubscriber:
 	for {
-		s.logger.Info("GoChannel #6", logFields)
+		s.logger.Trace("GoChannel #6", logFields)
 		// copy the message to prevent ack/nack propagation to other consumers
 		// also allows to make retries on a fresh copy of the original message
 		msgToSend := msg.Copy()
@@ -371,7 +371,7 @@ SendToSubscriber:
 			return
 		}
 
-		s.logger.Info("GoChannel #7", logFields)
+		s.logger.Trace("GoChannel #7", logFields)
 		select {
 		case s.outputChannel <- msgToSend:
 			s.logger.Trace("Sent message to subscriber", logFields)
