modulepackage
0.0.0-20230731063033-5001e0378cbb
Repository: https://github.com/komron-m/rabbitmq.git
Documentation: pkg.go.dev
# README
Overview
Main goal of this repository is to be able automatically re-connect to rabbitmq and resume consuming messages.
- auto-reconnection
- restore-consumers
All connection, publishing, consuming logic here are just handy wrappers of https://github.com/rabbitmq/amqp091-go. I assume
that you have a good understanding of rabbitmq and leave you a full example of how it may look like in your
project in cmd
directory. Otherwise, start learning here: https://rabbitmq.com/getstarted.html
Install
go get -u github.com/komron-m/rabbitmq
Contributing
Pull requests are welcome. For any changes, please open an issue first to discuss what you would like to change.
# Packages
No description provided by the author
# Functions
Dial a handy wrapper for base "github.com/rabbitmq/amqp091-go" DialConfig function.
No description provided by the author
No description provided by the author
# Structs
AMQPConsumer collects all parameters required for creating a queue and consuming messages.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
ExchangeParams and all other underlying structs created for compacting amqp091-go `function` parameters.
No description provided by the author
No description provided by the author
No description provided by the author
# Interfaces
An IConsumer handles an amqp message (delivery - in terms of github.com/rabbitmq/amqp091-go library).
# Type aliases
No description provided by the author