Added

dramatiq.Message.decode now raises a dramatiq.DecodeError on exception. (#375, @thomazthz)

Changed

The RabbitMQ broker moves messages that fail to decode to the DLQ. (#375, @thomazthz)

The Redis broker is now more defensive in how it handles re-enqueueing messages. This should fix a potential race condition where a worker could hit its heartbeat timeout but still end up re-enqueueing messages (thus ending up with the same message id enqueued multiple times). (#266, #395)
A code path that could lead to an unbound variable error has now been fixed. (#382)
Deleting the connection off of a RabbitMQ broker now correctly closes it and its associated channel (if any) before removing it from the broker. (#381, #384)