package pkg import ( "github.com/streadway/amqp" "log" ) func getConnection() *amqp.Connection { conn, err := amqp.Dial("amqp://guest:guest@rabbitmq:5672/") failOnError(err, "Failed to connect to RabbitMQ") return conn } func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } }