func setUpExchange()

in main.go [17:28]


func setUpExchange(conn *amqp.Connection, exchangeName string) {
	rmqChan, chanErr := conn.Channel()
	if chanErr != nil {
		log.Fatal("Could not establish initial connection to rabbitmq: ", chanErr)
	}
	defer rmqChan.Close()

	declErr := rmqChan.ExchangeDeclare(exchangeName, "topic", true, false, false, false, nil)
	if declErr != nil {
		log.Fatal("Could not declare channel: ", declErr)
	}
}