Go Rabbitmq

main.go

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	amqp "github.com/rabbitmq/amqp091-go"
)

func failOnError(err error, msg string) {
	if err != nil {
		log.Panicf("%s: %s", msg, err)
	}
}

func DeclareQueue(ch *amqp.Channel, name string, durable bool) amqp.Queue {
	q, err := ch.QueueDeclare(
		name,    // name
		durable, // durable
		false,   // delete when unused
		false,   // exclusive
		false,   // no-wait
		nil,     // arguments
	)
	failOnError(err, "Failed to declare a queue")
	fmt.Printf("Queue: %s created.\n", q.Name)
	return q
}

func Send(ch *amqp.Channel, queue string, message string, contentType string) {
	q := DeclareQueue(ch, queue, true)

	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	body := message
	err := ch.PublishWithContext(ctx,
		"",     // exchange
		q.Name, // routing key
		false,  // mandatory
		false,  // immediate
		amqp.Publishing{
			ContentType: contentType,
			Body:        []byte(body),
		})
	failOnError(err, "Failed to publish a message")
	log.Printf(" [x] Sent %s\n", body)
}

func Consume(ch *amqp.Channel, name string) {
	msgs, err := ch.Consume(
		name,             // queue
		"consumer-em-go", // consumer
		false,            // auto-ack
		false,            // exclusive
		false,            // no-local
		false,            // no-wait
		nil,              // args
	)
	failOnError(err, "Failed to register a consumer")

	var forever chan struct{}

	go func() {
		for d := range msgs {
			log.Printf("Received a message: %s", d.Body)
			log.Printf("\nContentType:%s\n", d.ContentType)
			log.Printf("\nConsumerTag:%s\n", d.ConsumerTag)
			log.Printf("\nTimestamp:%s\n", d.Timestamp)
			log.Printf("\nMessageId:%s\n", d.MessageId)
			log.Printf("\nPriority:%s\n", d.Priority)
			d.Ack(true)
		}
	}()

	log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
	<-forever
}

func main() {
	conn, err := amqp.Dial("amqps://user:pass@host/vhos")
	failOnError(err, "Failed to connect to RabbitMQ")
	defer conn.Close()
	ch, err := conn.Channel()
	failOnError(err, "Failed to open a channel")
	defer ch.Close()
	//Send(ch, "hello", "Hello World", "text/plain")
	Consume(ch, "hello")
}