diff --git a/pkg/service/connect_service.go b/pkg/service/connect_service.go
index 1aea0faa2..a089c67dc 100644
--- a/pkg/service/connect_service.go
+++ b/pkg/service/connect_service.go
@@ -185,10 +185,10 @@ func (s *ConnectService) EventStream(
 
 func (s *ConnectService) Notify(n Notification) {
 	s.eventingConfiguration.mu.RLock()
+	defer s.eventingConfiguration.mu.RUnlock()
 	for _, send := range s.eventingConfiguration.subs {
 		send <- n
 	}
-	s.eventingConfiguration.mu.RUnlock()
 }
 
 func (s *ConnectService) ResolveBoolean(