Posts

Showing posts from November, 2017

Working with Redis queues using rmq library in Golang

Rmq : Redis Messaging Queue Github : https://github.com/adjust/rmq Section 1 : Lets look at adding new items into a Redis queue from a Go routine The following is a producer routine in Golang. It will create a queue named “things” inside the Redis server, and store items inside it. Redis implements the queue as a double-ended Queue allowing push and pop from both ends of the same queue. The items are timestamps recorded by the Go routine. package main import(         "fmt"         "time"         "strconv"         "github.com/adjust/rmq" ) func main(){         connection := rmq.OpenConnection("test_producer", "tcp","localhost:6379", 1)         things := connection.OpenQueue("things")         defer...