.. References .. |AgeLimit| replace:: :class:`AgeLimit` .. |Barriers| replace:: :class:`Barriers` .. |Brokers| replace:: :class:`Brokers` .. |Broker| replace:: :class:`Broker` .. |Callbacks| replace:: :class:`Callbacks` .. |CurrentMessage| replace:: :class:`CurrentMessage` .. |DramatiqError| replace:: :class:`DramatiqError` .. |Encoders| replace:: :class:`Encoders` .. |GenericActors| replace:: :class:`class-based actors` .. |Groups| replace:: :func:`Groups` .. |Interrupt| replace:: :class:`Interrupt` .. |MemcachedRLBackend| replace:: :class:`Memcached` .. |Messages| replace:: :class:`Messages` .. |MiddlewareError| replace:: :class:`MiddlewareError` .. |Prometheus| replace:: :class:`Prometheus` .. |RabbitmqBroker_join| replace:: :meth:`join` .. |RabbitmqBroker| replace:: :class:`RabbitmqBroker` .. |RateLimitExceeded| replace:: :class:`RateLimitExceeded` .. |RateLimiters| replace:: :class:`RateLimiters` .. |RedisBroker| replace:: :class:`RedisBroker` .. |RedisRLBackend| replace:: :class:`Redis` .. |RedisResBackend| replace:: :class:`Redis` .. |ResultBackends| replace:: :class:`ResultBackends` .. |ResultBackend| replace:: :class:`ResultBackend` .. |ResultFailure| replace:: :class:`ResultFailure` .. |ResultMissing| replace:: :class:`ResultMissing` .. |ResultTimeout| replace:: :class:`ResultTimeout` .. |Results| replace:: :class:`Results` .. |Retries| replace:: :class:`Retries` .. |ShutdownNotifications| replace:: :class:`ShutdownNotifications` .. |Shutdown| replace:: :class:`Shutdown` .. |SkipMessage| replace:: :class:`SkipMessage` .. |StubBroker_flush_all| replace:: :meth:`StubBroker.flush_all` .. |StubBroker_flush| replace:: :meth:`StubBroker.flush` .. |StubBroker_join| replace:: :meth:`StubBroker.join` .. |StubBroker| replace:: :class:`StubBroker` .. |TimeLimitExceeded| replace:: :class:`TimeLimitExceeded` .. |TimeLimit| replace:: :class:`TimeLimit` .. |URLRabbitmqBroker| replace:: :class:`URLRabbitmqBroker` .. |WindowRateLimiter| replace:: :class:`WindowRateLimiter` .. |Worker_join| replace:: :meth:`Worker.join` .. |Worker_pause| replace:: :meth:`Worker.pause` .. |Worker_resume| replace:: :meth:`Worker.resume` .. |Worker| replace:: :meth:`Worker` .. |actor| replace:: :func:`actor` .. |add_middleware| replace:: :meth:`add_middleware` .. |after_skip_message| replace:: :meth:`after_skip_message` .. |before_consumer_thread_shutdown| replace:: :meth:`before_consumer_thread_shutdown` .. |before_worker_thread_shutdown| replace:: :meth:`before_worker_thread_shutdown` .. |dramatiq| replace:: :mod:`dramatiq` .. |get_current_message| replace:: :meth:`get_current_message` .. |group| replace:: :func:`group` .. |pipeline_get_results| replace:: :meth:`get_results` .. |pipeline_get_result| replace:: :meth:`get_result` .. |pipeline| replace:: :func:`pipeline` .. |rate_limits| replace:: :mod:`dramatiq.rate_limits` .. |send_with_options| replace:: :meth:`send_with_options` .. |send| replace:: :meth:`send` .. _gevent: http://www.gevent.org/ .. _Memcached: http://memcached.org .. _RabbitMQ: https://www.rabbitmq.com .. _Redis: https://redis.io