fix(deps): update module github.com/threedotslabs/watermill to v1.5.1

[renovate]

This PR contains the following updates:

Package	Change	Age	Confidence
github.com/ThreeDotsLabs/watermill	v1.1.1 -> v1.5.1

---

Release Notes

ThreeDotsLabs/watermill (github.com/ThreeDotsLabs/watermill)

v1.5.1

Compare Source

What's Changed

• Bump deps and examples by @​m110 in #​604
• Update docs by @​m110 in #​605
• Add CommandEventMarshalerDecorator by @​m110 in #​610
• Add AddConsumerHandler (rename AddNoPublisherHandler) by @​m110 in #​611

Full Changelog: ThreeDotsLabs/watermill@v1.5.0...v1.5.1

v1.5.0

Compare Source

What's Changed

• chore: fix function in comment by @​chengehe in #​578
• Add handler name to logs of handler.handleMessage() by @​HansvdLaanNedap in #​592
• docs: fix mismatched kafka pubsub examples by @​alexandregv in #​587
• refactor: replace []byte(fmt.Sprintf) with fmt.Appendf by @​minxinyi in #​585
• docs: Clarify partitioning key in Kafka example documentation by @​abramovd in #​577
• Bump github.com/redis/go-redis/v9 from 9.7.0 to 9.7.3 in /_examples/real-world-examples/delayed-requeue by @​dependabot[bot] in #​549
• Bump golang.org/x/net from 0.28.0 to 0.36.0 in /tools/mill by @​dependabot[bot] in #​546
• Bump vite from 5.4.8 to 5.4.12 in /docs by @​dependabot[bot] in #​541
• add memory clean up on gochannel subscribe topics when they no longer have any more subscribers by @​dkotik in #​561
• Use errors.Is for error comparison instead of direct equality checks by @​ytnsym in #​502
• Refactored sending lock of subscriber by @​stephanvanzwienen in #​589
• Update watermill-sql in examples by @​m110 in #​532
• Adds feature to use ULID in tests by @​HolyKingCrusader in #​444
• Clean up resources in Go channel pub sub [Memory leak] by @​avlajcic-axilis in #​407
• Add NewMessageWithContext() by @​m110 in #​596
• Tests: Make asserts less verbose by @​m110 in #​595
• docs: Fix spelling error: 'ques' to 'queues' in SNS configuration aws.md by @​pxwanglu in #​597
• Allow for custom labels on prometheus metrics by @​matdurand in #​393
• Upgrade github.com/cenkalti/backoff to v5 by @​EvanMad in #​570
• Uncancel context when retrying by @​roblaszczak in #​598
• Update TestMessageContext by @​m110 in #​599
• Add context propogation to subscribers for local pub-sub by @​yashb042 in #​487

New Contributors

• @​chengehe made their first contribution in #​578
• @​HansvdLaanNedap made their first contribution in #​592
• @​alexandregv made their first contribution in #​587
• @​minxinyi made their first contribution in #​585
• @​abramovd made their first contribution in #​577
• @​ytnsym made their first contribution in #​502
• @​stephanvanzwienen made their first contribution in #​589
• @​HolyKingCrusader made their first contribution in #​444
• @​avlajcic-axilis made their first contribution in #​407
• @​pxwanglu made their first contribution in #​597
• @​matdurand made their first contribution in #​393
• @​EvanMad made their first contribution in #​570
• @​yashb042 made their first contribution in #​487

Full Changelog: ThreeDotsLabs/watermill@v1.4.7...v1.5.0

v1.4.7

Compare Source

What's Changed

• don't log context cancellation as error in handler by @​roblaszczak in #​555
• nacking messages when context canceled by @​roblaszczak in #​556
• Clarify comment for Addhandler and multiple topics by @​addshore in #​551
• Add nkonev/watermill-opentelemetry by @​nkonev in #​553
• refactor: use slices.Contains to simplify code by @​whosehang in #​559
• Remove hashicorp/go-multierror by @​co60ca in #​550
• Linter: Added support for multi-go.mod repos by @​roblaszczak in #​569
• remove obsolete .golangci.yml by @​roblaszczak in #​573
• Make the retry middleware more flexible by @​xico42 in #​582

New Contributors

• @​addshore made their first contribution in #​551
• @​nkonev made their first contribution in #​553
• @​whosehang made their first contribution in #​559
• @​co60ca made their first contribution in #​550
• @​xico42 made their first contribution in #​582

Full Changelog: ThreeDotsLabs/watermill@v1.4.6...v1.4.7

v1.4.6

Compare Source

What's Changed

• • Added EventName(to event_processor) and CommandName(to command_proc… by @​unaik in #​548

New Contributors

• @​unaik made their first contribution in #​548

Full Changelog: ThreeDotsLabs/watermill@v1.4.5...v1.4.6

v1.4.5

Compare Source

What's Changed

• remove handler groups from _examples/basic/5-cqrs-protobuf and polish it a bit by @​roblaszczak in #​525
• update example real-world-example consumer-groups refactor cqrs.Facad… by @​ygaros in #​542
• feat(cqrs): add ability to return handlers for CQRS EventProcessor and d CommandProcessor by @​ekazakas in #​544

New Contributors

• @​ygaros made their first contribution in #​542
• @​ekazakas made their first contribution in #​544

Full Changelog: ThreeDotsLabs/watermill@v1.4.4...v1.4.5

v1.4.4

Compare Source

What's Changed

• another try to fix race condition by @​roblaszczak in #​540
• deprecate cqrs.ProtobufMarshaler (with github.com/gogo/protobuf) in favour of cqrs.ProtoMarshaler by @​roblaszczak in #​526

Suggested migration steps for cqrs.ProtobufMarshaler

cqrs.ProtobufMarshaler from this release is backward and forward compatible with cqrs.ProtoMarshaler.
cqrs.ProtobufMarshaler from Watermill versions until v1.4.3 are not forward compatible with cqrs.ProtoMarshaler.
Suggested migration steps:

1. Update Watermill to v1.4.4 or newer, so all publishers and subscribers will be forward and backward compatible.
2. Change all usages of cqrs.ProtobufMarshaler to cqrs.ProtoMarshaler.

Full Changelog: ThreeDotsLabs/watermill@v1.4.3...v1.4.4

v1.4.3

Compare Source

What's Changed

• Fix typos by @​NathanBaulch in #​512
• message: fix struct name in comment by @​hongmengning in #​520
• Example SSE: lock the versions of used Vue package so the example runs. by @​thpk in #​514
• fix race condition in TestMapExpiringKeyRepositoryCleanup by @​roblaszczak in #​535
• added ForceShort for test features by @​roblaszczak in #​537

New Contributors

• @​NathanBaulch made their first contribution in #​512
• @​hongmengning made their first contribution in #​520

Full Changelog: ThreeDotsLabs/watermill@v1.4.2...v1.4.3

v1.4.2

Compare Source

What's Changed

• docs: Add benchmark by @​m110 in #​516
• added PostgreSQL Caveats by @​roblaszczak in #​518
• use generic CQRS handlers in all examples by @​roblaszczak in #​519
• chore: fix the readme word spelling by @​weiye-Lee in #​524
• Update codecov settings by @​m110 in #​533
• fix flaky TestEventProcessor_handler_group by @​roblaszczak in #​534

New Contributors

• @​weiye-Lee made their first contribution in #​524

Full Changelog: ThreeDotsLabs/watermill@v1.4.1...v1.4.2

v1.4.1

Compare Source

What's Changed

• Router: publish messages in bulk by @​m110 in #​513

Full Changelog: ThreeDotsLabs/watermill@v1.4.0...v1.4.1

v1.4.0

Compare Source

What's Changed

• Add "Releases" link to docs by @​m110 in #​481
• docs: Fix menu position by @​m110 in #​482
• docs: Add Plausible by @​m110 in #​483
• allow generating test topics and sending non-empty messages by @​roblaszczak in #​490
• feat(metrics): custom histogram buckets configuration by @​thejoeejoee in #​489
• Replace kafka-console-consumer with mill util by @​KirylJazzSax in #​478
• Add NewDefaultRouter constructor by @​m110 in #​493
• Update Getting Started by @​m110 in #​494
• Docs v2 by @​m110 in #​498
• docs: Fix og rendering by @​m110 in #​500
• Bump amqp to v3 by @​m110 in #​503
• Add test helpers to codecov ignore by @​m110 in #​504
• Docs cosmetics by @​roblaszczak in #​505
• Requeuer and Message Delay by @​m110 in #​469
• Add AWS examples by @​m110 in #​507
• Slog level mapping by @​roblaszczak in #​510
• added AWS v1.0 docs by @​roblaszczak in #​506
• Add more docs on requeue by @​m110 in #​509

New Contributors

• @​KirylJazzSax made their first contribution in #​478

Full Changelog: ThreeDotsLabs/watermill@v1.3.7...v1.4.0

v1.3.7

Compare Source

What's Changed

• Fix tests running concurrent publish with the same messages by @​m110 in #​479

Full Changelog: ThreeDotsLabs/watermill@v1.3.6...v1.3.7

v1.3.6

Compare Source

This release includes lots of smaller patches and updates, as well as many new contributors! Thank you, everyone, for submitting PRs!

What's Changed

• fix: typo in forwarder.md by @​Smixi in #​400
• Change the autogenerated topic name to conform with Azure limits by @​unjello in #​425
• Fix missed topic names non-conforming to Azure policy by @​unjello in #​426
• docs: add watermill-rediszset to unofficial libraries by @​stong1994 in #​427
• Add deduplication middleware and publisher decorator by @​dkotik in #​423
• ci: update setup-go and checkout to latest action versions by @​AlexCuse in #​406
• Examples: update watermill-sql to v3 by @​thpk in #​419
• Add msgFields to the Error log call by @​ivaaaan in #​410
• fix function name by @​looklose in #​431
• all: fix a lot of typos by @​mountcount in #​438
• Add configuration option to allow ignoring command reply publishing errors by @​balenio in #​441
• chore: fix comment by @​finaltrip in #​448
• SSE htmx example by @​m110 in #​435
• SSE example: more efficient handlers by @​m110 in #​453
• Add unofficial AMQP 1.0 pubsub link by @​kahowell in #​454
• [watermill-http] Custom HTTP response status by @​thejoeejoee in #​450
• docs: add note on NATS jetstream beta package by @​AlexCuse in #​405
• Add envs and run up before codecov by @​m110 in #​458
• Examples: Pause SSE to save resources by @​m110 in #​468
• Fix docker compose in validate examples by @​m110 in #​470
• Bump golang.org/x/net from 0.5.0 to 0.7.0 in /_examples/pubsubs/redisstream by @​dependabot in #​353
• Added lock for message.Router.middlewares by @​SargtLa in #​465
• Update dependencies by @​m110 in #​473
• update mill install command by @​roblaszczak in #​452
• Update mill dependencies by @​m110 in #​477

New Contributors

• @​Smixi made their first contribution in #​400
• @​unjello made their first contribution in #​425
• @​stong1994 made their first contribution in #​427
• @​thpk made their first contribution in #​419
• @​ivaaaan made their first contribution in #​410
• @​looklose made their first contribution in #​431
• @​mountcount made their first contribution in #​438
• @​balenio made their first contribution in #​441
• @​finaltrip made their first contribution in #​448
• @​kahowell made their first contribution in #​454
• @​thejoeejoee made their first contribution in #​450
• @​SargtLa made their first contribution in #​465

Full Changelog: ThreeDotsLabs/watermill@v1.3.5...v1.3.6

v1.3.5

Compare Source

What's Changed

• Add Circuit Breaker docs by @​m110 in #​390
• Request/reply support by @​roblaszczak in #​397
• Add SlogLoggerAdapter by @​dkotik in #​355

New Contributors

• @​dkotik made their first contribution in #​355 🎉

Full Changelog: ThreeDotsLabs/watermill@v1.3.4...v1.3.5

v1.3.4

Compare Source

Forwarder: propagate the enveloped message's Context (#​387)

v1.3.3

Compare Source

Add Circuit Breaker middleware (#​380)

v1.3.2

Compare Source

#​372 - Default to NopLogger if a nil logger is passed to NewRouter - thank you, @​vladtenlive!

v1.3.1

Compare Source

What's Changed

• Fix logging an error when router is closed due to context cancellation by @​hlubek in #​370

New Contributors

• @​hlubek made their first contribution in #​370

Full Changelog: ThreeDotsLabs/watermill@v1.3.0...v1.3.1

v1.3.0

Compare Source

What's Changed

• Docs: update for nats jetstream by @​AlexCuse in #​334
• Update examples deps by @​roblaszczak in #​335
• Add Consumer Groups example by @​m110 in #​348
• Update consumer groups example by @​m110 in #​352
• Correct link of doc about Pub/Sub implementation supported by watermill by @​tjnet in #​357
• Docs: include JetStreamConfig detail in nats pubsub documentation by @​AlexCuse in #​358
• Added support for Event Handler groups and new CQRS public API by @​roblaszczak in #​367

New Contributors

• @​tjnet made their first contribution in #​357

Full Changelog: ThreeDotsLabs/watermill@v1.2.0...v1.3.0

v1.2.0

Compare Source

Below is a compilation of the changes from release candidates:

• Add Forwarder component (#​187)
• Expose Prometheus metrics at /metrics endpoint (#​168) - thanks @​lebaptiste!
• Added extra TestConcurrentSubscribeMultipleTopics test (#​196)
• Fixed docs (thanks @​xswordsx and @​sagikazarmark!)
• Accepting a prometheus.Registerer allows using prometheus.DefaultRegisterer (#​204) - thanks @​sagikazarmark!
• [bugfix] Proper Message nil m.ack handling (#​227) - thanks @​oxbambooxo
• [tests] Initialize subscribers for each consumer group (#​225) - thanks @​breml
• [examples] Add Server-Sent Events example (#​209) - thanks @​m110
• [docs] small docs updates - thanks @​kochetkov-av and @​m110
• [bugfix] Proper Message nil m.ack handling (#​227) - thanks @​oxbambooxo
• [tests] Initialize subscribers for each consumer group (#​225) - thanks @​breml
• [examples] Add Server-Sent Events example (#​209) - thanks @​m110
• [docs] small docs updates - thanks @​kochetkov-av and @​m110
• Add watermill-firestore to the list of Pub/Subs (#​234) - thanks @​boreq!
• Return the handler instance created within AddNoPublisherHandler (#​229) - thanks @​terev!
• Add mill googlecloud subscription ls (#​220) - thanks @​maclav3!
• Update deps and Go for CI
• Stress tests updates and bugfixes
• Documentation improvements #​246, #​252, #​254, #​255, #​257 - thanks @​boreq & @​m110!
• Pass Context to Forwarder's wrapped message (#​263) - thanks @​m110!
• Implement FanIn component (#​221) - thanks @​0michalsokolowski0!
• Fix a blocking subscriber prevents other subscribers from receiving a message (#​256) - thanks @​boreq!
• Allowing to add handlers while the router is already running (#​266)
• Added backward compatible build tags
• Add IsRunning method to the router (#​270) - thanks @​checkmunza!
• Changes to Pubsub Test for ExactlyOnce (#​269) - thanks @​AlexCuse!
• Add docs on publishing messages in transactions with help of the Forwarder component (#​261) - thanks @​czeslavo!
• Router handlers method for router plugins #​289 - thanks @​dangerousplay!
• update test setting (#​329)

---

Configuration

📅 Schedule: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined).

🚦 Automerge: Disabled by config. Please merge this manually once you are satisfied.

♻ Rebasing: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox.

🔕 Ignore: Close this PR and you won't be reminded about this update again.

---

• If you want to rebase/retry this PR, check this box

---

This PR was generated by Mend Renovate. View the repository job log.

[renovate]

ℹ Artifact update notice

File name: go.mod

In order to perform the update(s) described in the table above, Renovate ran the go get command, which resulted in the following additional change(s):

• 1 additional dependency was updated
• The go directive was updated for compatibility reasons

Details:

Package	Change
go	1.16 -> 1.23.0
github.com/stretchr/testify	v1.7.0 -> v1.11.0

[renovate]

ℹ️ Artifact update notice

File name: go.mod

In order to perform the update(s) described in the table above, Renovate ran the go get command, which resulted in the following additional change(s):

• 1 additional dependency was updated
• The go directive was updated for compatibility reasons

Details:

Package	Change
go	1.16 -> 1.23.0
github.com/stretchr/testify	v1.7.0 -> v1.11.0