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)

go get -u github.com/sbabiv/rmqconn

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"),
    })
}

MIT

Babiv Sergey