watermill
watermill copied to clipboard
ThreeDotsLabs
Building event-driven applications the easy way in Go.
I needed a way to listen to any message sent via the GoChannel Pub/Sub that didn't have a subscriber yet. This was mainly used for debugging but it could be...
## Issue Part of the issue reported here https://github.com/ThreeDotsLabs/watermill/issues/391 After testing, I've found same issue in `Publish` method. It uses `LoadOrStore` for fetching `subLock`. https://github.com/ThreeDotsLabs/watermill/blob/d20a6051456863fa147b9f9034b66500a6f0ffdf/pubsub/gochannel/pubsub.go#L96 That means if lock for...
We recently had an outage due to (incorrect) configuration of Retry without Poison. However, one of the items that came out of that was a realization that we didn't really...
follow-up handler will be broke while before msg handler error, what is the best practice for this situation？
Hi, I'm trying to add flow control on my subscription with `MaxOutstandingMessages` setting. I'm setting it to 1, with streaming pull request, but it seems this is not working. I'm...
Hey. I have noticed that router does not pass fields of the message [here](https://github.com/ThreeDotsLabs/watermill/blob/master/message/router.go#L777): ``` if err != nil { h.logger.Error("Handler returned error", err, nil) msg.Nack() return } ``` What...
Hi It looks like current AMQP pub/sub implementation doesn't re-create queues after reconnection. It cause errors in case of "exclusive" or "auto-delete" queues in RabbitMQ: > cannot consume from channel:...
Metadata
Owner
Metadata
Building event-driven applications the easy way in Go.