proxy.golang.org : github.com/mdigger/rabbitmq
Библиотека rabbitmq для работы с сервером RabbitMQ является вспомогательной и построена поверх github.com/rabbitmq/amqp091-go. В неё добавлено понятие инициализаторов каналов соединения — на их основе осуществляется автоматическое подключение к серверу и восстановление состояния. Для установки соединения с сервером и инициализации обработчиков используется метод Run (синхронный) или Init (асинхронный), которые позволяют задать несколько Initializer. Эти обработчики будут вызываться при каждой установке соединения, чтобы восстановить топологию и заново проинициализировать работу сервиса. В библиотеки представлены два генератора таких инициализаторов: Consume для обработки входящих сообщений и Publish для публикации. Для инициализации одновременной обработки входящих событий и публикации новых можно воспользоваться вспомогательной функцией Work.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/mdigger/rabbitmq
Keywords:
golang
, rabbit-mq
, rabbit-reconnect
, rabbitmq
, rabbitmq-client
, rabbitmq-consumer
, rabbitmq-producer
License: MIT
Latest release: almost 3 years ago
First release: almost 3 years ago
Namespace: github.com/mdigger
Stars: 0 on GitHub
Forks: 0 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 10 days ago