-
Notifications
You must be signed in to change notification settings - Fork 3.9k
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
Enforce/honor per-vhost queue limit for all protocols #11222
Enforce/honor per-vhost queue limit for all protocols #11222
Conversation
724c60b
to
7b21b48
Compare
46af406
to
d2192fb
Compare
Enforce/honor per-vhost queue limit for all protocols (backport #11222)
This PR adds a regression: rabbitmq-server/deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl Lines 1357 to 1383 in ad6c173
|
@ansd Hmmm, totally missed that check. It would only check if twice with a 'false' result I guess... Although something could slip in-between perhaps. I can update the mqtt_processor code to just handle the protocol error return value of rabbit_queue_type:declare? |
That would be great, thank you! |
Proposed Changes
The current vhost queue limit it's only applicable to AMQP 0.9.1 and "non-native" protocols.
This PR moves the check to
rabbit_queue_type:declare
Types of Changes
What types of changes does your code introduce to this project?
Put an
x
in the boxes that applyChecklist
Put an
x
in the boxes that apply.You can also fill these out after creating the PR.
If you're unsure about any of them, don't hesitate to ask on the mailing list.
We're here to help!
This is simply a reminder of what we are going to look for before merging your code.
CONTRIBUTING.md
documentFurther Comments
If this is a relatively large or complex change, kick off the discussion by explaining why you chose the solution
you did and what alternatives you considered, etc.