Skip to content
RabbitMQ Reconnection client
Go
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.gitignore
.travis.yml
LICENSE
README.md
connector.go
connector_test.go
types.go

README.md

Build Status Coverage Status Go Report Card GoDoc Mentioned in Awesome Go

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

Or, using dep:

dep ensure -add 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

MIT

Author

Babiv Sergey

You can’t perform that action at this time.