diff --git a/src/modules/monapi/cron/event_consumer.go b/src/modules/monapi/cron/event_consumer.go index 94610165..9207ff04 100644 --- a/src/modules/monapi/cron/event_consumer.go +++ b/src/modules/monapi/cron/event_consumer.go @@ -58,7 +58,7 @@ func consume(event *model.Event) { SetEventStatus(event, model.STATUS_UPGRADE) if needNotify { - if event.EventType == config.ALERT && NeedCallback(event.Sid) { + if NeedCallback(event.Sid) { if err := PushCallbackEvent(event); err != nil { logger.Errorf("push event to callback queue failed, callbackEvent: %+v", event) } @@ -82,7 +82,7 @@ func consume(event *model.Event) { return } - if event.EventType == config.ALERT && NeedCallback(event.Sid) { + if NeedCallback(event.Sid) { if err := PushCallbackEvent(event); err != nil { logger.Errorf("push event to callback queue failed, callbackEvent: %+v", event) }