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