github.com/ThreeDotsLabs/watermill

What's Changed

• Propagate AddConsumerHandler to examples and docs by @m110 in #612
• Add quickstart docs by @m110 in #615
• Update Quickstart link in README by @m110 in #618
• Polish watermill.io after update by @roblaszczak in #619
• Update Pub/Sub links to latest versions by @m110 in #620
• added sqlite docs PoC by @roblaszczak in #563
• edit SQLite documentation and transaction example by @dkotik in #621
• Refresh getting started by @m110 in #628
• docs: add suport of mysql delayed messages by @AdrianZajkowski in #630
• refactor: use maps.Copy to simplify the code by @dulanting in #627
• docs: update discord link by @m110 in #634
• chore: fix some comments by @geogrego in #635
• refactor: remove redundant variable declarations in for loops by @efcking in #637
• chore: execute goimports to format the code by @xibeiyoumian in #644
• Rename variable from pub to sub in main.go by @sdil in #643
• I can't see anything by @boreq in #674
• Bump dependencies and fix races by @m110 in #679
• Bump vite from 5.4.12 to 5.4.21 in /docs by @dependabot[bot] in #629
• Bump picomatch from 2.3.1 to 2.3.2 in /docs by @dependabot[bot] in #680
• docs: assorted documentation and comment improvements by @jjpinto in #647
• Fix HTTP response body leak and add retry backoff in run.go by @jjpinto in #665
• Validate all examples + fix by @m110 in #681
• Added support for custom JSON configuration in the forwarder component by @falboe in #667
• feat(retry): add OnRetriesExhausted hook for cleanup actions by @Br1an67 in #670
• Restore PR CI by @m110 in #682

New Contributors

• @AdrianZajkowski made their first contribution in #630
• @dulanting made their first contribution in #627
• @geogrego made their first contribution in #635
• @efcking made their first contribution in #637
• @xibeiyoumian made their first contribution in #644
• @sdil made their first contribution in #643
• @jjpinto made their first contribution in #647
• @falboe made their first contribution in #667
• @Br1an67 made their first contribution in #670

Full Changelog: v1.5.1...v1.5.2

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: v1.5.0...v1.5.1

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: v1.4.7...v1.5.0

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: v1.4.6...v1.4.7

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: v1.4.5...v1.4.6

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: v1.4.4...v1.4.5

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: v1.4.3...v1.4.4

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: v1.4.2...v1.4.3

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: v1.4.1...v1.4.2

What's Changed

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

Full Changelog: v1.4.0...v1.4.1