fixing go channeling

STollenaar · Sep 24, 2023 · 068da73 · 068da73
1 parent 14d0954
commit 068da73
Showing 1 changed file with 10 additions and 13 deletions.
diff --git a/internal/sqspoller/sqspoller.go b/internal/sqspoller/sqspoller.go
@@ -38,21 +38,18 @@ func init() {
 
 func PollSQS() {
 	for {
-		select {
-		case <-sqsObjectChannel:
-			sqsObject := <-sqsObjectChannel
-			fmt.Printf("Handling object %v\n", sqsObject)
-			switch sqsObject.Type {
-			case "url":
-				handleURLObject(sqsObject)
-			case "user":
-				handleUserObject(sqsObject)
-			default:
-				fmt.Printf("Unknown type has been send to queue. sqsObject is: %v", sqsObject)
-			}
-
+		sqsObject := <-sqsObjectChannel
+		fmt.Printf("Handling object %v\n", sqsObject)
+		switch sqsObject.Type {
+		case "url":
+			handleURLObject(sqsObject)
+		case "user":
+			handleUserObject(sqsObject)
+		default:
+			fmt.Printf("Unknown type has been send to queue. sqsObject is: %v", sqsObject)
 		}
 	}
+
 }
 
 func pollSQS() {