-
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
Auto deleted queue log #611
Conversation
This needs some work, as explained on Slack. It currently uses not particularly clear wording and doesn't distinguish between exclusive and auto-delete queues, which have different removal reasons/events. |
@@ -142,6 +142,8 @@ init_it(Recover, From, State = #q{q = #amqqueue{exclusive_owner = Owner}}) -> | |||
{_, Terms} = recovery_status(Recover), | |||
BQS = bq_init(BQ, Q, Terms), | |||
%% Rely on terminate to delete the queue. | |||
log_auto_delete("Exclusive query connection closed", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
You probably mean "queue", not "query". Also, this conflates exclusive and auto-delete queues. That's confusing, please use separate functions with clearer wording (as discussed on Slack).
Fixes #590
Added some functionality to logging:
error_logger
messages. Works same way asrabbit_
sinks.