Как организовать асинхронную публикацию сообщений в RabbitMQ с использованием Golang?

Question

Я пытаюсь организовать публикацию асинхронных сообщений в RabbitMQ, используя этот популярный пакет go для RabbitMQ:

https://godoc.org/github.com/streadway/amqp

В библиотеке заявлена ​​поддержка асинхронной публикации.Но я не смог найти пример.Я также не смог найти функцию, которая принимала бы функцию обратного вызова в качестве входных данных.

Может ли кто-нибудь помочь с простым примером асинхронной публикации на Golang?

Answer 1

Я нашел клиентскую библиотеку для этой задачи.

https://github.com/streadway/amqp

По умолчанию реализован асинхронный обмен сообщениями.

Может быть для кого-то это будет полезно.