What's Changed

• Inject raw Delivery.Redelivered in message.Message to deduce duplicate message by @samartha-kar23 in #32

New Contributors

• @samartha-kar23 made their first contribution in #32

Full Changelog: v3.0.1...v3.0.2

What's Changed

• fix: error message paths in config.go by @AceFire6 in #31

New Contributors

• @AceFire6 made their first contribution in #31

Full Changelog: v3.0.0...v3.0.1

What's Changed

• Change Build Topology to accept the routing key and topic by @m110 in #27
  • Original changes by @tobiasjaster in #19

This version extends the topology builder to allow using the routing key.

It fixes ThreeDotsLabs/watermill#305

Upgrading to v3

If you use the default TopologyBuilder, you don't need to do anything.

If you implement a custom TopologyBuilder, update the BuildTopology method. It now takes params amqp.BuildTopologyParams instead of queueName string, exchangeName string.

-	BuildTopology(channel *amqp.Channel, queueName string, exchangeName string, config Config, logger watermill.LoggerAdapter) error
+	BuildTopology(channel *amqp.Channel, params BuildTopologyParams, config Config, logger watermill.LoggerAdapter) error

Inside the method, replace queueName with params.QueueName and exchangeName with params.ExchangeName.

Full Changelog: v2.1.3...v3.0.0

What's Changed

• Bump deps by @m110 in #28

Full Changelog: v2.1.2...v2.1.3

What's Changed

• Recreate topology after reconnection by @m110 in #25
• Inspired by #17 by @reva2 and #21 by @shaneing

Full Changelog: v2.1.1...v2.1.2

• Use message context when publishing (#22 - thank you @igtulm!)

Skip connection validation for NewPublisherWithConnection (#18)

Delivery confirmation of published messages #15

fix: Deadlock in subscriber consuming loop #14