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)
}
}