switch to buffered chan, due to multiple contemporaneus events

led0nk · Jun 10, 2024 · dcbf3fd · dcbf3fd
1 parent 4ff7459
commit dcbf3fd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/events/event.go b/pkg/events/event.go
@@ -40,7 +40,7 @@ func (e *EventManager) Subscribe(name string) (uuid.UUID, <-chan EventMessage) {
 		return uuid.Nil, nil
 	}
 
-	ch := make(chan EventMessage)
+	ch := make(chan EventMessage, 5)
 	e.subscriber[id] = ch
 
 	e.logger.Info("service subscribed to eventManager", "service id", id, "service name", name)
@@ -65,6 +65,7 @@ func (e *EventManager) Publish(emsg EventMessage) {
 		case ch <- emsg:
 			e.logger.Debug("publish eventMessage", "debug", "publish", subscriber.String(), fmt.Sprintf("%s", emsg))
 		default:
+			e.logger.Debug("channel blocked, skipping subscriber", "subscriber", subscriber.String())
 		}
 	}
 }