diff --git a/order_client.go b/order_client.go index c6749d7..5f57258 100644 --- a/order_client.go +++ b/order_client.go @@ -24,12 +24,12 @@ type RabbitTransportClient struct { func (t *RabbitTransportClient) declareBindAndConsume(topic string) (<-chan amqp.Delivery, error) { q, err := t.channel.QueueDeclare( - "", // name - false, // durable - false, // delete when unused - true, // exclusive - false, // no-wait - nil, // arguments + "orders", // name + false, // durable + false, // delete when unused + true, // exclusive + false, // no-wait + nil, // arguments ) if err != nil { return nil, err