watermill

watermill copied to clipboard

[amazonsqs] Refactor the utils.go and marshaller/unmarshaller into separate packages

5

Move those common components out of the `amazonsqs` package into a separate `utils` package?

p4tin

### Goal Ensure payloads send using the publisher confirm as valid message types. Users of watermill should not be concerned with ensuring that their payload is valid for the publisher...

56KBs

feat(metrics): add opentelemetry support

1

Signed-off-by: ahkui #574 ### Motivation / Background Implement metrics collection using the OpenTelemetry MeterProvider ### Detail Implement metrics collection using the OpenTelemetry MeterProvider ### Alternative approaches considered (if applicable) ###...

ahkui

## Feature request N/A ### Description N/A ### Example use case integrate with opentelemetry #### How it can look like in code ```go // ... metricsBuilder := metrics.NewOpenTelemetryMetricsBuilder() metricsBuilder.AddPrometheusRouterMetrics(router) //...

ahkui

### Motivation / Background Watermill currently uses an obsolete version of the [Exponential Backoff Go Package](https://github.com/cenkalti/backoff). This upgrades Watermill from using v3 to v5. This upgrade contains multiple breaking changes,...

EvanMad

Pub/Sub suport for Pocketbase

1

## Feature Request It would be great to have support for using [[PocketBase](https://pocketbase.io/)](https://pocketbase.io/) as a Pub/Sub source for [[Watermill](https://github.com/ThreeDotsLabs/watermill)](https://github.com/ThreeDotsLabs/watermill). I am using Pocketbase and would like to use Watermill to...

eugeis

## Feature request ### Description Add a new configuration option to the retry middleware that would make it possible to customize which types of errors are retryable. ### Example use...

xico42

Some Watermill internal tests are written with null payloads

3

https://github.com/ThreeDotsLabs/watermill-sql/blob/master/pkg/sql/pubsub_test.go#L466 has null payloads: ```go messagesToPublish := []*message.Message{ message.NewMessage("0", nil), message.NewMessage("1", nil), message.NewMessage("2", nil), } ``` The acceptance tests never run a scenario with a NULL payload. Using that test...

dkotik

# Concurrency Issue: Context Cancellation During Router Shutdown Causes In-flight Handlers to Fail ## Description There appears to be a race condition in the router shutdown process that causes in-flight...

mscno

Allow choosing the nack method

1

Hello, I would like to be able to choose the Nack method used depending on the message processing. ### Example ```go // file: watermill/message.go type Message strut {} func (m...

babariviere