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

GoChannel subsciber blocked without Acking messages #275

Open
upils opened this issue Mar 23, 2022 · 0 comments
Open

GoChannel subsciber blocked without Acking messages #275

upils opened this issue Mar 23, 2022 · 0 comments

Comments

@upils
Copy link

upils commented Mar 23, 2022

In the current implementation, the goroutine executing sendMessageToSubscriber() is blocked until either the message is acked/nacked or the subsciber is closing.

I will submit a PR soon.

upils pushed a commit to upils/watermill that referenced this issue Mar 23, 2022
Signed-off-by: Paul MARS <paul.mars@intrinsec.com>
upils pushed a commit to upils/watermill that referenced this issue Mar 23, 2022
Signed-off-by: Paul MARS <paul.mars@intrinsec.com>
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

No branches or pull requests

1 participant