rmq
rmq copied to clipboard
adjust
Message queue system written in Go and backed by Redis
redis-go now provides a UniversalClient for connection. I will suggest removing the dependency on redis.Client, and replace that with redis.UniversalClient which covers the various aspects of client management from rmq.
After a message pops up from Redis, if the system goes down at this time, will the message be lost?
I'm trying to handle a requirement where a consumer can get killed. And when it comes back it should retry to task it was performing. I have 2 push queue...
Hi, I don't know if this is by design - but after stopping to consume a Queue via `StopConsuming`, it is impossible to resume consuming via `StartConsuming`. The problem is...
In nodejs [rsmq](https://github.com/smrchy/rsmq) is pretty popular, it has been ported to rust as [rsmq_async](https://docs.rs/rsmq_async/2.1.0/rsmq_async/). For some reasons, I need to use rmq in golang, and use rust rsmq_async as a...
Could you please let us know what are the best practices we need to follow when using this package like number of connections, should we create a new connection every...
`github.com/adjust/rmq` depends on `github.com/adjust/gocheck` which depends on the now deprecated `launchpad.net/gocheck` (which also uses `bzr` instead of `git` causing additional issues). Any chance you could change the dependency here to...
Hi, I stumbled upon you lib recently its been very helpful and i am very grateful that you have put such tremendous effort into making it but i find the...
What is the suggested approach to scale for throughput? I am using rmq for a project which needs high throughput. If I need to increase throughput from producer -> Q...
Use redis.Nil in TestRedisClient.RPop to match the behavior of the redis client
