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

Recreate topology after reconnection #17

Closed
wants to merge 1 commit into from

Conversation

reva2
Copy link

@reva2 reva2 commented Dec 2, 2022

@reva2
Copy link
Author

reva2 commented Dec 2, 2022

@m110 can you please review and approve this PR?

@marlongerson
Copy link

marlongerson commented Jan 12, 2023

I am also running into this issue where subscription is not re-established on reconnect. This fixes the issue.

Comment on lines +237 to +240
if err = s.prepareConsume(queueName, exchangeName, logFields); err != nil {
s.logger.Error("Failed to prepare consume", err, logFields)
return
}
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@reva2 The issue here might be that you won't receive this error on the first subscriber run (it's just logged). Perhaps it makes sense to run s.prepareConsume in all these cases?

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Although that might cause duplicated logs so it's also not an elegant solution. 🤔

@darri89
Copy link

darri89 commented May 31, 2024

Any movement on this? I would very much love to see this feature.

@m110
Copy link
Member

m110 commented Jun 27, 2024

See #25 - the issue with this approach is that the initial error would not be returned, but only logged.

@m110 m110 closed this Jun 27, 2024
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.

[watermill-amqp] Issue with exclusive or auto-delete queues after reconnection
4 participants