rmq
rmq copied to clipboard
adjust
Message queue system written in Go and backed by Redis
Hello, I noticed that if the producer is running and the consumer stopped working for some reason when the consumer restarted it doesn't start where it finished, hence some unknown...
Looking in this file: https://github.com/adjust/rmq/blob/master/redis_wrapper.go#L10-L74 Why is there logic that actively prevents context from being passed to the redis commands? Any issue with exposing additional logic that has all these...
I was trying out the library against a redis cluster. With the last change, I am able to connect to the cluster but when I initiate the consumer I get...
Add the ability to start a queue that has been stopped by resetting the queue settings and channels when finishing stopping the consumers. The old consumers are removed when you...
``` taskConsumer := &TaskConsumer{} name, err := taskQueue.AddConsumer("task-consumer", taskConsumer) ``` At your example i give error on `&TaskConsumer{}`. Couldn't find that 
Thoughts on this? The scenario I've come across where I need this is that there are situations where you might want to push a message to the prescribed push queue,...
After reading the "MOVED" error is due to instantiate a client to a clustered redis Db, I tried several options using redis.NewClusterCLienat, redis.NewClient and when ready to establish the connection...
https://redis.io/topics/streams-intro Just a question, is support for redis streams planned?
Currently when RMQ has established a connection it will send a heartbeat, which sets a value with a 1 minute TTL, every second. This tells the queue cleaner that this...
