Categorygithub.com/komron-m/rabbitmq
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