Потеря некоторых сообщений при публикации в очереди rabbitmq

Question

Я работаю над проектом с использованием go и rabbitmq. Когда я публикую большое количество сообщений, некоторые сообщения не публикуются в очереди.

Я использую следующий код для публикации сообщений в очереди

func Publish(queue commonModel.Queue, content []byte) commonModel.Queue {

    error := queue.Channel.Publish(
        "",
        queue.Name,
        false, // mandatory
        false, // immediate
        amqp.Publishing{

            DeliveryMode: amqp.Persistent,
            ContentType:  "application/json",
            Body:         []byte(content),
        })

    queue.Error = error

    return queue
}

Кто-нибудь знает, почему некоторые сообщения не публикуются в очереди?