fix: bug in eventstore.go

Raezil · Dec 7, 2024 · 26df127 · 26df127
1 parent dbed127
commit 26df127
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/eventstore.go b/eventstore.go
@@ -194,14 +194,6 @@ func (eventstore *EventStore) BroadcastWithRabbitMQ() error {
 			continue
 		}
 
-		// Publish the event to RabbitMQ
-		err := eventstore.PublishToRabbitMQ(event)
-		if err != nil {
-			log.Printf("Failed to publish event ID %s: %v", event.Id, err)
-			lastErr = err // Record the last error encountered
-			continue
-		}
-
 		// Optionally, handle the event if there's a dispatcher
 		if eventstore.Dispatcher != nil {
 			handler, exists := (*eventstore.Dispatcher)[event.Projection]