- Inspect error codes instead of assuming a string value
- Use
MKSTREAM
command - Support consumers reading from end of stream
- Add a supervisor for each consumer
- Handle shutdown of a consumer gracefully
- Fix typespecs around mfa() and handler()
- Remove deprecated
Supervisor.Spec
usage
- Bump up dependencies to redix 0.8.2
- Bump up dependencies to Elixir 1.7 and redix 0.7.1
- Added official Redis consumer group support (thanks @jeffutter)
- Added a simple tracker concept to allow for safe consumer restarts.
- Initial version