finish event push to nsq

nbtca · Mar 24, 2024 · 6e2d9e9 · 6e2d9e9
1 parent c44dedd
commit 6e2d9e9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/util/event-action.go b/util/event-action.go
@@ -193,9 +193,9 @@ func (eh *eventActionHandler) Handle() model.EventLog {
 	} else {
 		eventLog = eh.createEventLog(createEventLogArgs{})
 	}
-	logger := Logger
+	logger := getLogger()
 	if producer := GetNSQProducer(); producer != nil {
-		logger.Hooks.Add(&NSQHookForError{
+		logger.Hooks.Add(&NSQHookForEvent{
 			Producer: producer,
 		})
 	}

diff --git a/util/logger.go b/util/logger.go
@@ -32,9 +32,9 @@ func (hook *NSQHookForError) Fire(entry *logrus.Entry) error {
 	return hook.Producer.Publish("log_topic", byte)
 }
 
-// Levels 返回日志级别，这里只返回 ErrorLevel
+// Levels 返回日志级别，这里返回 ErrorLevel,FatalLevel,PanicLevel
 func (hook *NSQHookForError) Levels() []logrus.Level {
-	levels := [1]logrus.Level{logrus.ErrorLevel}
+	levels := [3]logrus.Level{logrus.ErrorLevel, logrus.FatalLevel, logrus.PanicLevel}
 	return levels[:]
 }