> ConsumerSet: Now possible to add/cancel consumers at runtime > > * To add another consumer to an active set do: > >     cset.add_consumer(C) >     # or >     cset.add_consumer_from_dict(**declaration) >     # ... >     # consume() will declare new consumers >     cset.consume() > > * To cancel an active consumer by queue name do: > >     cset.cancel_by_queue(queue_name) >
> ConsumerSet: Now possible to add/cancel consumers at runtime
>
> * To add another consumer to an active set do:
>
>     cset.add_consumer(C)
>     # or
>     cset.add_consumer_from_dict(**declaration)
>     # ...
>     # consume() will declare new consumers
>     cset.consume()
>
> * To cancel an active consumer by queue name do:
>
>     cset.cancel_by_queue(queue_name)
>

ask/carrot,ask/carrot