📚 rmqconn - Awesome Go Library for Messaging
RabbitMQ Reconnection. Wrapper over amqp.Connection and amqp.Dial. Allowing to do a reconnection when the connection is broken before forcing the call to the Close () method to be closed.
🏷️ Messaging
📂 Libraries that implement messaging systems.
⭐ 23 stars
Detailed Description of rmqconn
rmqconn
RabbitMQ Reconnection for Golang
Wrapper over amqp.Connection
and amqp.Dial
. Allowing to do a reconnection when the connection is broken before forcing the call to the Close () method to be closed
Use the default method func Dial (url string) (Conner, error)
to connect to the server.
You can implement your connection function and pass it to rmqconn.Open("", customFunc)
Getting started
1. install
go get -u github.com/sbabiv/rmqconn
2. use it
conn, err := rmqconn.Open("amqp://usr:pwd@host:5672", rmqconn.Dial)
defer conn.Close()
if err != nil {
return
}
if conn.IsConnected() {
ch, err := conn.GetChannel()
if err != nil {
return
}
defer ch.Close()
err = ch.Publish("", "queueName", false, false, amqp.Publishing{
Body: []byte("hello wolrd"),
})
}
Licence
Author
Babiv Sergey