watermill

watermill copied to clipboard

Swap message after sometime

1

I am using Watermill to develop software where I send a message, and it goes through service1, service2, and the last service. I use a slice to control the order...

dramirezp

I see that this [PR](https://github.com/ThreeDotsLabs/watermill-sql/pull/28) added support for ExactlyOnceDelivery for Postgres, but the documentation may not have been updated to reflect this. Also, I was reading your tests, and noticed...

thirumal-rafay

roblaszczak

roblaszczak

Use errors.Is for error comparison instead of direct equality checks

1

This PR refactors error handling by replacing direct comparisons of errors (e.g., err == someError) with the use of errors.Is.

ytnsym

Redisstream example dosn't work

4

The redisstream example here **_examples/pubsubs/redisstream** not working. [watermill] 2024/09/04 15:28:02.855927 subscriber.go:182: level=INFO msg="Subscribing to redis stream topic" consumer_group=test_consumer_group consumer_uuid=9N2bRGgtYCcRU2hE3dMJiV provider=redis topic=example.topic [watermill] 2024/09/04 15:28:02.855969 subscriber.go:203: level=INFO msg="Starting consuming" consumer_group=test_consumer_group consumer_uuid=9N2bRGgtYCcRU2hE3dMJiV...

rifaideen

https://github.com/ThreeDotsLabs/watermill-nats/blob/master/pkg/nats/subscriber.go#L185

sheldygg

How I can set different queue group for every subscriber?

1

Hi, looks like issues disabled [here](https://github.com/ThreeDotsLabs/watermill-nats), so I have opened this issue in this repo. How I can set different queue group for every subsciber? I must create new `nats.SubscriberConfig`...

sheldygg

Add context propogation to subscribers for local pub-sub

4

Solves Issue - [https://github.com/ThreeDotsLabs/watermill/issues/464](url) **Update 1 -** Have not added extra variables in Message struct, because the Message struct is used by every publisher-subscriber **Update 2 -** Couldn't test the...

yashb042

``` --- FAIL: TestRouter_context_cancel_does_not_log_error (3.00s) router_test.go:1357: Error Trace: /home/runner/work/watermill/watermill/message/router_test.go:1357 Error: Condition never satisfied Test: TestRouter_context_cancel_does_not_log_error Messages: Router should be closed after all handlers are stopped FAIL ``` https://github.com/ThreeDotsLabs/watermill/actions/runs/10736759138/job/29776849651

m110