search

achilleasa / dart_amqp

Dart AMQP client implementing protocol version 0.9.1
MIT License
79 stars 40 forks source link

The "qos" function does not work in queues of the "stream" type. #68

Closed alexanderkind closed 2 years ago

alexanderkind commented 3 years ago

Hi! RabbitMQ requires separate "qos" settings for each new consumer. (global = false) https://www.rabbitmq.com/consumer-prefetch.html#overview

The abstract class "Channel" in the "qos" function is missing the "global" parameter. This will fix everything.

Thanks!

achilleasa commented 2 years ago

FYI, the 0.2.2 release includes this change.