MQ is a generic interface to abstract the details of implementation of messaging queues systems.

Similar to the package database/sql, this package implements a common interface to interact with different message queue systems, in a unified way.

The recommended way to install mq is:

go get github.com/go-mq/mq/v2 

This example shows how to publish and consume a Job from the in-memory implementation, very useful for unit tests.

The mq implementations to be supported by the NewBroker should be imported as shows the example.

package main import ( "fmt" "github.com/go-mq/mq/v2" _ "github.com/go-mq/mq/v2/memory" "log" ) //... func main() { b, _ := mq.NewBroker("memory://") q, _ := b.Queue("test-queue") j := mq.NewJob() if err := q.Publish(j); err != nil { log.Fatal(err) } iter, err := q.Consume(1) if err != nil { log.Fatal(err) } consumedJob, _ := iter.Next() var payload string _ = consumedJob.Decode(&payload) fmt.Println(payload) // Output: hello world! }

Apache License Version 2.0, see LICENSE