Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Allow channel.qos() invocations to set the value of the global param #82

Merged
merged 1 commit into from
Nov 2, 2022

Conversation

achilleasa
Copy link
Owner

The value of the global flag is interpreted differently between the AMQP 0-9-1 spec and RabbitMQ.

For RabbitMQ, if global is true, then prefetchCount is shared between all consumers of this channel. Otherwise, prefetchCount is applied separately to each new consumer of the channel.

According to the AMQP spec, if global is true, then prefetchCount is shared between all consumers on the connection. Otherwise, prefetchCount is shared between all consumers of this channel.

For more information see https://www.rabbitmq.com/consumer-prefetch.html

Fixes #68

The value of the `global` flag is interpreted differently between the AMQP 0-9-1
spec and RabbitMQ.

For RabbitMQ, if `global` is true, then `prefetchCount` is shared between
all consumers of this channel. Otherwise, `prefetchCount` is applied
separately to each new consumer of the channel.

According to the AMQP spec, if `global` is true, then `prefetchCount` is
shared between all consumers on the connection. Otherwise,
`prefetchCount` is shared between all consumers of this channel.

For more information see https://www.rabbitmq.com/consumer-prefetch.html
@coveralls
Copy link

Coverage Status

Coverage remained the same at 93.115% when pulling 1f6d90b on support-per-consumer-qos into 9e41b8e on master.

@achilleasa achilleasa merged commit 2120ef3 into master Nov 2, 2022
@achilleasa achilleasa deleted the support-per-consumer-qos branch November 2, 2022 20:28
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

The "qos" function does not work in queues of the "stream" type.
2 participants