|
|
@ -35,8 +35,8 @@ func (d *Declarator) Declare(bindings []ExchangeBinding) error { |
|
|
for _, binding := range bindings { |
|
|
for _, binding := range bindings { |
|
|
err := d.chanManager.ExchangeBindSafe( |
|
|
err := d.chanManager.ExchangeBindSafe( |
|
|
binding.From, |
|
|
binding.From, |
|
|
binding.To, |
|
|
|
|
|
binding.RoutingKey, |
|
|
binding.RoutingKey, |
|
|
|
|
|
binding.To, |
|
|
binding.NoWait, |
|
|
binding.NoWait, |
|
|
tableToAMQPTable(binding.Args), |
|
|
tableToAMQPTable(binding.Args), |
|
|
) |
|
|
) |
|
|
|