diff --git a/pipeline/missing-item-type-resolver/main.go b/pipeline/missing-item-type-resolver/main.go index 1ee72f3..5a9bb8f 100644 --- a/pipeline/missing-item-type-resolver/main.go +++ b/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 {} }