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.