This repository has been archived by the owner on Aug 31, 2021. It is now read-only.
Release v2.0.0-beta.1
Pre-release
Pre-release
jpwilliams
released this
09 Jan 16:06
·
212 commits
to master
since this release
Overview
Adding demissions. This is a big, evil change.
The original plan was to use rabbitmq/rabbitmq-delayed-message-exchange
, though this seems to have a tonne of problems with load and inaccurate timings.
Instead I've gone with creating a separate queue for each demission (bypassing RabbitMQ's per-message TTL caveat), allowing the use of dead-letter exchanges to push messages to the right queue at the right time.
New features
- Set up a
before
function for demissions: daee6a3 - Set up mad demission bits. We’re making a queue for every message. Is that bad?: a1984cc
Bug fixes / generic changes
- Fiddling with these tests to have them pass even on slow VMs: 8524fca
- Only ever send a single argument as a message; all other parameters are extraneous: a8cd3f0
- If a message has been scheduled, pass that through in the resulting event: 0becae8
- Adding a simple usage example for demissions, mainly proving they work: 22e43e9
- Fix for demissions cancelling when the publisher disconnects: 45aeff0