lol... "completed"...

pipeline/missing-item-type-resolver/main.go

@@ -53,7 +53,7 @@ type NSQHandler struct {
 }
 
 func (h *NSQHandler) HandleMessage(message *nsq.Message) error {
-	logger.Info("Received message: %s", string(message.Body))
+	// logger.Info("Received message: %s", string(message.Body))
 	itemTypeID, err := strconv.ParseInt(string(message.Body), 10, 32)
 	if err != nil {
 		logger.Error("Failed to parse item_type_id from message: %v", err)
@@ -109,5 +109,5 @@ func main() {
 
 	logger.Info("Connected to NSQ, consuming from topic: %s, channel: %s", Topic, Channel)
 
-	logger.Info("Missing item type resolver completed")
+	select {}
 }