This package uses the package provided by the RabbitMQ core team.
Provide auto reconnect
go get -u github.com/elvin-tacirzade/go-amqp
First we call a New() function. The function takes the following parameters:
user- Declare a RabbitMQ user.password- Declare a RabbitMQ passwordhost- Declare a RabbitMQ hostport-Declare a RabbitMQ portreconnectTime- Declare an auto reconnect time
New() function returns the RabbitMQ struct and error.
See the example subdirectory for simple consumers executables.