Merge 704df4b into 46e352a

linkedin · Oct 23, 2019 · bd64bca · bd64bca
2 parents 46e352a + 704df4b
commit bd64bca
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/core/internal/notifier/coordinator.go b/core/internal/notifier/coordinator.go
@@ -553,6 +553,11 @@ func (nc *Coordinator) notifyModule(module Module, status *protocol.ConsumerGrou
 		return
 	}
 
+	// Only send the open notification once if send-once is configured
+	if (!cgroup.LastNotify[module.GetName()].IsZero()) && viper.GetBool("notifier."+moduleName+".send-once") {
+		return
+	}
+
 	// Only send the notification if it's been at least our Interval since the last one for this group
 	currentTime := time.Now()
 	if currentTime.Sub(cgroup.LastNotify[module.GetName()]) > (time.Duration(viper.GetInt("notifier."+moduleName+".send-interval")) * time.Second) {