diff --git a/internal/handler/messaging.go b/internal/handler/messaging.go index 7e68b2e..6281397 100644 --- a/internal/handler/messaging.go +++ b/internal/handler/messaging.go @@ -40,16 +40,6 @@ func (h *Messaging) processMessageQueue(message mq.Message) { var insights InsightsData var resource ResourceDestination - // set up defer to ack the message after we're done processing - - //defer func(message mq.Message) { - // // Ack to remove from queue - // err := message.Ack(false) - // if err != nil { - // fmt.Printf("Failed to acknowledge message: %s\n", err.Error()) - // } - //}(message) - acknowledgeMessage := func(message mq.Message) func() { return func() { // Ack to remove from queue