You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm trying to detect unexpected consumer cancellations.
Based on https://www.rabbitmq.com/consumer-cancel.html
ChannelCallback::cancel() seems to be the best for this, but I can't make it work.
Hi,
I'm trying to detect unexpected consumer cancellations.
Based on https://www.rabbitmq.com/consumer-cancel.html
ChannelCallback::cancel() seems to be the best for this, but I can't make it work.
I tried doing something like this:
But ChannelCallback::cancel() was not called.
Did I miss some configuration?
Probable cause
I've read here https://www.rabbitmq.com/connections.html#capabilities
that this extension (consumer_cancel_notify) needs to be present in client capabilities, otherwise RabbitMQ does not send any notification.
I modified Connection::open() to check if it would help, and it did.
![amqprs missing client capabilities](https://private-user-images.githubusercontent.com/82613828/278866074-d3530265-31ae-450f-9bf8-07a9740afd57.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjIxMjY3NjAsIm5iZiI6MTcyMjEyNjQ2MCwicGF0aCI6Ii84MjYxMzgyOC8yNzg4NjYwNzQtZDM1MzAyNjUtMzFhZS00NTBmLTliZjgtMDdhOTc0MGFmZDU3LnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MjglMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzI4VDAwMjc0MFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWFjMzRkZTc2OTBkNjA1MTQ0ZmQxMDVlMjhlMzM5MWFkOTZhMjI1ZTJiYTlkZmU2YTA1NTQxNGRjNGZiZTQzZjkmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.7gQbf_RghylRTWUdiKqEyESNm9w2L9dbszm1rAu1VDw)
versions:
Rust: 1.73
amqprs: 1.5.0
The text was updated successfully, but these errors were encountered: