watermill

watermill copied to clipboard

[watermill-redisstream] Subscribers can pick up up to 2 tasks while busy with another task

1

The current implementation for subscribers essentially starts 3 different routines: 1. one reads messages from the stream, and pushes it to a channel 2. another one monitors pending messages, and...

wk8

I couldn't figure out how to do this easily in a reasonable way so I will describe it here in case someone has any ideas. Currently there already exists a...

boreq

Replace kafka-console-consumer with mill util. Resolves #130 Is it okay to add an executable to one of the containers?

KirylJazzSax

Requeuer and Message Delay

1

* Added the `Requeuer` component. * It works as a simpler version of the Forwarder, routing messages from one topic to another (a dynamic one). * Can be used to...

m110

If you take a look at the Timeout middleware: ``` func Timeout(timeout time.Duration) func(message.HandlerFunc) message.HandlerFunc { return func(h message.HandlerFunc) message.HandlerFunc { return func(msg *message.Message) ([]*message.Message, error) { ctx, cancel :=...

turip

Replace protobuf and remove gogo/protobuf

1

Good day! This PR replaces the direct dependency on [github.com/golang/protobuf with google.golang.org/protobuf](https://github.com/ThreeDotsLabs/watermill/commit/0e87d46ab9901e75c39e041cfe4bfd8952087b4f) to avoid using a deprecated package. Doing this included adding the generation code to the Makefile to make...

boekkooi-terramate

Replace original context in pub/sub GoChannel (SendToSubscriber)

6

Hi you have replaced original msg context with msgToSend.SetContext(ctx) and we lost the original context! so to speak : when we call msg.Copy() we don't set original context on new...

bi0dread

Use errors and fmt package to join and wrap errors

4

Good day! First of thank you for maintaining and providing the watermill package! I opened this PR because I noticed that the `hashicorp/go-multierror` and `github.com/pkg/errors` where added as an indirect...

boekkooi-terramate

I can help with adding golangci-lint checkers to avoid issues

3

I can help with adding golangci-lint checkers to avoid issues such had the one I spotted in #460 _Originally posted by @ccoVeille in https://github.com/ThreeDotsLabs/watermill/pull/460#issuecomment-2265243587_

ccoVeille

The handlerExecutionTimeBuckets in handler.go are not exposed or configurable. Some clients will be processing messages where the processing time is typically many seconds to minutes. For the clients, the all...

sshort