From b3744595950b328ba08671c77f92421103cc2790 Mon Sep 17 00:00:00 2001
From: Andy Librian <andylibrian@gmail.com>
Date: Thu, 2 May 2024 15:12:52 +0700
Subject: [PATCH] WIP

---
 pkg/server/ingestion_worker.go | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/pkg/server/ingestion_worker.go b/pkg/server/ingestion_worker.go
index ff2390f..a37008a 100644
--- a/pkg/server/ingestion_worker.go
+++ b/pkg/server/ingestion_worker.go
@@ -59,13 +59,11 @@ func (iw *IngestionWorker) loopConsumeQueue(queue protoqueue.QueueSubscriber) {
 		}
 	}()
 
-	go func() {
-		defer iw.logger.Info("stopped consuming events from ingestion queue")
+	defer iw.logger.Info("stopped consuming events from ingestion queue")
 
-		for event := range eventChan {
-			iw.processEvent(event)
-		}
-	}()
+	for event := range eventChan {
+		iw.processEvent(event)
+	}
 }
 
 func (iw *IngestionWorker) processEvent(event *tarianpb.Event) {