From 513f8eda60889721ee9f82f81275dee57b18bcf6 Mon Sep 17 00:00:00 2001
From: kercylan98 <kercylan@gmail.com>
Date: Thu, 27 Apr 2023 20:13:50 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 notify/manager.go | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/notify/manager.go b/notify/manager.go
index f41c60a..13c13d5 100644
--- a/notify/manager.go
+++ b/notify/manager.go
@@ -1,5 +1,11 @@
 package notify
 
+import (
+	"go.uber.org/zap"
+	"minotaur/utils/log"
+	"reflect"
+)
+
 func NewManager(senders ...Sender) *Manager {
 	manager := &Manager{
 		senders:       senders,
@@ -13,15 +19,19 @@ func NewManager(senders ...Sender) *Manager {
 			case <-manager.closeChannel:
 				close(manager.closeChannel)
 				close(manager.notifyChannel)
+				log.Info("Manager", zap.String("state", "release"))
 				return
 			case notify := <-manager.notifyChannel:
 				for _, sender := range manager.senders {
-					sender.Push(notify)
+					if err := sender.Push(notify); err != nil {
+						log.Error("Manager", zap.String("sender", reflect.TypeOf(sender).String()), zap.Error(err))
+					}
 				}
 			}
 		}
 	}()
 
+	log.Info("Manager", zap.String("state", "running"))
 	return manager
 }