go get github.com/inuggets/nmq

import "github.com/inuggets/nmq"

// Broker
broker := nmq.NewRedisBroker(&nmq.RedisOptions{
    URL:      "localhost:6379",
    Password: "",
})

// Producer
producer := nmq.NewProducer(broker)

// Produce
err := producer.Produce("topic", "message")
if err != nil {
    log.Fatal(err)
}

// Consumer
consumer := nmq.NewConsumer(broker, "topic")
for {
    message, err := consumer.Consume()
    if err != nil {
        log.Fatal(err)
    }
    
    if m == nil {
        time.Sleep(3 * time.Second) // If no message, waiting for a while
        continue
    } else {
        // Do something
        ...
         
        // Ack (will remove message from queue permanently)
        err := consumer.Ack(m)
        if err != nil {
            log.Default().Println(err)
        }
        
        // Or back to queue (will be consumed again)
        err := consumer.Back(m)
        if err != nil {
            log.Default().Println(err)
        }
    }
}