package main
import (
“context”
“log”
“gitlab.com/digitalxero/mqutils”
“gitlab.com/digitalxero/mqutils/types”
)
func main() {
// Works with any supported message queue system
consumer, err := mqutils.NewConsumer(“amqp://localhost:5672/myqueue”)
if err != nil {
log.Fatal(err)
}
defer consumer.Close()
// Register a message handler
consumer.RegisterHandler("process", func(msg types.Message) error {
    log.Printf("Received: %s", string(msg.Body()))
    return nil
})

// Start consuming messages
ctx := context.Background()
if err := consumer.Run(ctx); err != nil {
    log.Fatal(err)
}
}