Dramatiq

Added

* `RabbitmqBroker` now supports multiple connection uris to be passed in via its url parameter. (216, wsantos)

Changed

* Updated allowed version range for prometheus-client. (219, robinro)

Added

* `dramatiq_queue_prefetch` environment variable to control the number of messages to prefetch per worker thread. (183, 184, xelhark)
* The RabbitMQ broker now retries the queue declaration process if an error occurs. (179, davidt99)
* Support for accessing nested broker instances from the CLI. (191, bersace)
* Support for eagerly raising actor exceptions in the joining thread with the `StubBroker`. (195, 203)
* Support for accessing the current message from an actor via `CurrentMessage`. (208)

Changed

* Pinned pika version `>1.0,<2.0`. (202)

Fixed

* An issue where workers would fail and never recover after the connection to Redis was severed. (207)
* ``pipe_ignore`` has been fixed to apply to the next message in line within a pipeline. (194, metheoryt)

Added

* The RabbitMQ broker now supports native message priorities. (157, davidt99)
* Support for specifying the actor class to `actor`. (169, gilbsgilbs)

Changed

* Pika 0.13 is now required.

Fixed

* Consumers are now stopped after workers finish running their tasks. (160, brownan)
* Worker logging on Python 3.7 is no longer delayed.

Fixed

* Changed license classifier to the correct license. This is why you shouldn't publish changed before you've had coffee, folks!

**This release was removed from PyPI because it had a bad license classifier (GPLv3+ instead of LGPLv3+) due to a mistake on my part.**

Fixed

* License classifier in PyPI package. There were no source code
changes for this release.

Added

* Support for redis-py 3.x. (142, maerteijn)

Fixed

* Workers wait for RMQ messages to be acked upon shutdown. (148)
* Pipelines no longer continue when a message is failed. (151, davidt99)
* Log files now work under Windows. (141, ryansm1)