amqp: Channel.Publish blocks indefinitely

Channel.Publish sometimes blocks indefinitely. The following code is a test case to reproduce this. It reproduces most of time I run it. Adding a sleep between inside the for loop does not help.

package main

import (
	"log"

	"github.com/streadway/amqp"
)

func main() {

	const queueName = "q1"

	if conn, stdErr := amqp.Dial("amqp://guest:guest@localhost:5672/"); stdErr != nil {
		log.Fatalln(stdErr)
	} else if channel, stdErr := conn.Channel(); stdErr != nil {
		log.Fatalln(stdErr)
	} else if stdErr := channel.Confirm(false); stdErr != nil {
		log.Fatalln(stdErr)
	} else if _, stdErr := channel.QueueDeclare(
		queueName, //queue
		true,      //durable
		false,     //autodelete
		false,     //exclusive
		false,     //nowait
		nil,       //arguments
	); stdErr != nil {
		log.Fatalln(stdErr)
	} else {
		confirmationChan := channel.NotifyPublish(make(chan amqp.Confirmation))

		for i := 0; i < 10000; i++ {
			log.Println("publish ", i)

			if stdErr := channel.Publish(
				"",        // exchange
				queueName, // routing key
				false,     // mandatory
				false,     // immediate
				amqp.Publishing{
					Body: []byte{},
				}); stdErr != nil {
				log.Fatalln(stdErr)
			} else {
				log.Println("pre confirmation check")
				confirmation := <-confirmationChan
				log.Println("post confirmation check")
				if !confirmation.Ack {
					log.Fatalln("confirmation not ack")
				}
			}
			// time.Sleep(time.Millisecond * 1000)
		}
	}
}