- Use utility from openedx_events to reset application state before processing event
- Adds custom exceptions for producing and consuming errors.
- Option to limit length of stream.
- Updated README.
- BREAKING CHANGE: Removed deprecated
signal
argument from consumer.
- Deprecated
signal
argument in consumer (made optional in preparation for removal)
- Option to claim messages from other consumers based on idle time.
- Setting
check_backlog
will read messages that were not read by this consumer group.
- First release on PyPI.
- Redis streams consumer and producer implemented.