AMQP driver for mq
The initial driver that came with the fork of github.com/src-d/go-queue, added to a
separate repository to be used as a go module.
go get github.com/go-mq/mq-amqp/v1
Import mq and this driver to your project, and you should be good to go
import (
"github.com/go-mq/mq/v2"
_ "github.com/go-mq/mq-amqp/v1"
)
func main() {
b, _ := mq.NewBroker("amqp://my-rabbitmq.example.com:5672")
// now see docs of github.com/go-mq/mq for how to use it
}