watermill
watermill copied to clipboard
ThreeDotsLabs
Building event-driven applications the easy way in Go.
It does not seem like it is possible to generate queue bindings from the topic The `amqp.Config` allows providing a function to generate a queue binding ``` go QueueBind: QueueBindConfig{...
When any publisher is used inside middleware of a `message.Router` and a handler is registered with `router.AddNoPublisherHandler`, the `publisher_name` label in metrics is incorrect. ## Expected Run code at the...
Condition: * pub/sub provider use redis * use message router to handle all the message handler * publish 10 messages * handler function takes 5 seconds to process * Ctrl+C...
I would like to implement a way to inject a custom logger or logfields through `Message.Context`. Let me begin by addressing a problem we encountered. The issue we faced is...
@roblaszczak, @m110 I hope to contribute an SQLite driver some time this summer. I am opening this issue to collect ideas and to hear suggestions from you and the community....
Running code with `-race` that publishes from multiple goroutines at the same time: ``` WARNING: DATA RACE Write at 0x00c002c291d8 by goroutine 1498: github.com/ThreeDotsLabs/watermill-googlecloud/pkg/googlecloud.(*Publisher).Publish() github.com/ThreeDotsLabs/[email protected]/pkg/googlecloud/publisher.go:149 +0xe4 [...] Previous write at...
Hello. RabbitMQ can work with streams. You can work with streams either using the standard Amqp 0.9.1 library, with which the watermill-amqp package is implemented or using the new library...
Metadata
Owner
Metadata
Building event-driven applications the easy way in Go.