Golang AMQP

main.go

package main

import (
	"fmt"
	"github.com/streadway/amqp"
	"log"
)

func main() {
	connection, err := amqp.Dial("amqp://guest:guest@127.0.0.1:5672")

	if err != nil {
		panic("Could not connect to broker.")
	}

	defer connection.Close()

	channel, err := connection.Channel()

	if err != nil {
		panic("Could not open channel.")
	}

	defer channel.Close()

	for i := 0; i < 1000000; i++ {
		message := amqp.Publishing{
			Body: []byte("Testing 1 2 3..."),
		}

		err = channel.Publish("publisher", "", false, false, message)

		if err != nil {
			panic("Could not publish message.")
		}
	}

	fmt.Println("Done!")
}