Update broker.go

korol8484 · Jul 15, 2020 · c2bb4a1 · c2bb4a1
1 parent ef23479
commit c2bb4a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/amqp/broker.go b/broker/amqp/broker.go
@@ -69,7 +69,7 @@ func (b *Broker) Serve() (err error) {
 	defer b.consume.Close()
 
 	for _, q := range b.queues {
-		err := q.declare(b.publish, q.name, q.name, nil)
+		err := q.declare(b.publish, q.name, q.key, nil)
 		if err != nil {
 			b.mu.Unlock()
 			return err