AMQP worker adapter for Buffalo
This package implements the github.com/gobuffalo/buffalo/worker.Worker interface using the github.com/streadway/amqp package.
It allows AMQP-compatible message brokers, such as RabbitMQ, to process Buffalo's background tasks.
Setup
import "github.com/stanislas-m/amqp-work-adapter"
import "github.com/streadway/amqp"
// ...
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672")
if err != nil {
log.Fatal(err)
}
buffalo.New(buffalo.Options{
// ...
Worker: amqpw.New(amqpw.Options{
Connection: conn,
Name: "myapp",
MaxConcurrency: 25,
}),
// ...
})