watermill
watermill copied to clipboard
ThreeDotsLabs
Building event-driven applications the easy way in Go.
When publishing, the official Posgres uses a background context. When I was working on SQLite implementation, @roblaszczak recommended that I use context from the fist message being published. > publish...
This is an incremental update to use cenkalti/backoff/v4 rather than cenkalti/backoff/v3 and a notice that backoff/v5 requires some discussion from watermill maintainers. https://github.com/cenkalti/backoff/releases/tag/v3.2.2 was released in 2020 https://github.com/cenkalti/backoff/releases/tag/v4.3.0 and 4.3.0...
### Motivation / Background ### Detail ### Alternative approaches considered (if applicable) ### Checklist The resources of our team are limited. **There are a couple of things that you can...
### Steps to reproduce ```go package main import ( "time" "github.com/ThreeDotsLabs/watermill" "github.com/ThreeDotsLabs/watermill-googlecloud/pkg/googlecloud" "github.com/ThreeDotsLabs/watermill/message" "github.com/google/uuid" "google.golang.org/api/option" ) func main() { opts := []option.ClientOption{ option.WithCredentialsJSON([]byte("")), } cfg := googlecloud.PublisherConfig{ Marshaler: googlecloud.DefaultMarshalerUnmarshaler{}, ProjectID:...
This allows publishing and subscribing to narrowly focused topics that include random data like UUIDs in topic name. Without this change, memory usage will grow indefinitely in a long-running service...
## Feature request ### Description I would like to propose an enhancement to the Watermill library to improve message processing efficiency by implementing a worker pool for concurrent message processing....
## Feature request A MQTT pubsub implementation ### Description I have a need of a pubsub implementation to publish and subscribe messages to and from a MQTT server. Connections to...
Hello, I tried to set up watermill with Redis and Nats Jetstream and the messages I was sending kept going back on my server restart even tho I was doing...
## Feature request Expose `Redelivered` to consumer listening for messages on channel. ### Problem: Redelivered Flag Not Exposed According to the RabbitMQ [reliability docs](https://www.rabbitmq.com/docs/reliability#consumer-side), messages may be [redelivered](https://www.rabbitmq.com/docs/consumers#message-properties) in the...
## Feature request ### Description Support providing an external `sarama.Client` to the Kafka Subscriber. Currently, the `watermill-kafka` subscriber creates its own Sarama client internally. This makes it difficult to share...
Metadata
Owner
Metadata
Building event-driven applications the easy way in Go.