Hanndle When Channel Is Full

Signed-off-by: rodneyosodo <blackd0t@protonmail.com>

internal/clients/redis/producer.go

@@ -67,14 +67,22 @@ func (es *eventStore) Publish(ctx context.Context, event Event) error {
 		es.mu.Lock()
 		defer es.mu.Unlock()
 
-		es.unpublishedEvents <- record
+		select {
+		case es.unpublishedEvents <- record:
+		default:
+			// If the channel is full (rarely happens), drop the events.
+			return nil
+		}
+
 		return nil
 	}
 
 	return es.client.XAdd(ctx, record).Err()
 }
 
 func (es *eventStore) StartPublishingRoutine(ctx context.Context) {
+	defer close(es.unpublishedEvents)
+
 	ticker := time.NewTicker(unpublishedEventsCheckInterval)
 	defer ticker.Stop()