dramatiq
dramatiq copied to clipboard
Emit signal before call dramatiq.Consumer.consume
Emit signal befora call self.broker.consume
.
This idea is to solve this problem #472.
Before consuming the queue I can define through rules on my system if it is able or not by calling thread.stop()
in a middleware.