watermill
watermill copied to clipboard
ThreeDotsLabs
Building event-driven applications the easy way in Go.
Redis 5.0 release new data type: [Stream](https://redis.io/topics/streams-intro) That's really powerful mq now. Besides, redis below version 5, may use data type "list" to implement a mq (i think it should...
I wanted to try out the example of "5-cqrs-protobuf". On recreating the events.pb.go the example watermill fails with: ``` [watermill] 2022/04/21 10:52:50.101794 router.go:603: level=ERROR msg="Handler returned error" err="1 error occurred:...
The go-chi HTTP router used in the Watermill HTTP overrides added handlers for the same route. Because of that when calling `httpSubscriber.Subscribe(ctx, url)` with the same `url` N times it...
I can't find anywhere that the `Router` will call `Wait` method on `runningHandlersWg`. ```go type Router struct { ... handlersWg *sync.WaitGroup runningHandlersWg *sync.WaitGroup ... } ``` Should it need to...
I find myself thinking about adding a protobuf marshaler to watermill-jetstream and wondering if it would make sense to include the contract definitions and generated files in watermill itself.
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.
When I use a single consumer, subsequent messages cannot be consumed normally after Retry is triggered. ``` retryLoop: for { waitTime := expBackoff.NextBackOff() select { case
[watermill-nats] Watermill command bus cannot recover from "stan: connection closed" on Stan restart
Used in Kubernetes environment have to reschedule the Stan pod, which changed the underlying IP address which it used. After that the command bus was constantly throwing "sending message failed:...
Can you please support [Publisher Confirms](https://www.rabbitmq.com/confirms.html#publisher-confirms) for amqp?
Metadata
Owner
Metadata
Building event-driven applications the easy way in Go.