From 3cdf4036b2d396e5231a92995a6a944b0ae58bb4 Mon Sep 17 00:00:00 2001 From: PhatPhuckDave Date: Mon, 26 Jan 2026 12:55:49 +0100 Subject: [PATCH] lol... "completed"... --- pipeline/missing-item-type-resolver/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 {} }