package mainimport (	"github.com/streadway/amqp"	"log")func failOnError(err error, msg string) {	if err != nil {		log.Fatalf("%s: %s", msg, err)	}}func main()  {	conn,err := amqp.Dial("amqp://admin:admin@xx.xxx.xxx.xxx:5672/")	failOnError(err,"Failed to connect to RabbitMQ")	defer conn.Close()	ch,err := conn.Channel()	failOnError(err, "Failed to open a channel")	defer ch.Close()	q, err := ch.QueueDeclare(		"hello", // name		false,   // durable		false,   // delete when unused		false,   // exclusive		false,   // no-wait		nil,     // arguments	)	failOnError(err, "Failed to declare a queue")	body := "Hello World!"	err = ch.Publish(		"",     // exchange		q.Name, // routing key		false,  // mandatory		false,  // immediate		amqp.Publishing{			ContentType: "text/plain",			Body:        []byte(body),		})	failOnError(err, "Failed to publish a message")	log.Printf(" [x] Sent %s", body)}

package mainimport (	"github.com/streadway/amqp"	"log")func failOnErrors(err error, msg string) {	if err != nil {		log.Fatalf("%s: %s", msg, err)	}}func main()  {	conn,err := amqp.Dial("amqp://admin:admin@xx.xxx.xxx.xxx:5672/")	failOnErrors(err, "Failed to connect to RabbitMQ")	defer conn.Close()	ch, err := conn.Channel()	failOnErrors(err, "Failed to open a channel")	defer ch.Close()	q, err := ch.QueueDeclare(		"hello", // name		false,   // durable		false,   // delete when unused		false,   // exclusive		false,   // no-wait		nil,     // arguments	)	failOnErrors(err, "Failed to declare a queue")	msgs, err := ch.Consume(		q.Name, // queue		"",     // consumer		true,   // auto-ack		false,  // exclusive		false,  // no-local		false,  // no-wait		nil,    // args	)	failOnErrors(err, "Failed to register a consumer")	forever := make(chan bool)	go func() {		for d := range msgs {			log.Printf("Received a message: %s", d.Body)		}	}()	log.Printf(" [*] Waiting for messages. To exit press CTRL+C")	<-forever}