diff --git a/CHANGELOG.md b/CHANGELOG.md index 1b1eb89c80c2c2f7c1dd47854b8872c72d5e7821..1333119f3740919c6970d993a28d585377c9fb97 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -16,6 +16,7 @@ v2.0.0 * renamed publish(tx) to publish(confirm) * declare will expect qos to be given as an integer, and will be set as prefetch_count, since RabbitMQ no longer supports prefetch_size + * same can be said of Consumer.set_qos(prefetch_count) v1.5.0 ====== diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py index 723998e2d223eb037b902dd62136c9510e01a90d..78077085670e3c300c4a9ef388e83de6b1fbe1e7 100644 --- a/coolamqp/attaches/consumer.py +++ b/coolamqp/attaches/consumer.py @@ -84,10 +84,7 @@ class Consumer(Channeler): :param span: optional span, if opentracing is installed :param no_ack: Will this consumer require acknowledges from messages? :type no_ack: bool - :param qos: a tuple of (prefetch size, prefetch window) for this - consumer, or an int (prefetch window only). - If an int is passed, prefetch size will be set to 0 (which means - undefined), and this int will be used for prefetch window + :param qos: maximum messages to send to client that can stay unacknowledged (qos.prefetch_count) :type qos: int, prefetch_count to use :param cancel_on_failure: Consumer will cancel itself when link goes down