diff --git a/order_client.go b/order_client.go index 5f57258..8366396 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( - "orders", // name - false, // durable - false, // delete when unused - true, // exclusive - false, // no-wait - nil, // arguments + "order-queue", // name + false, // durable + false, // delete when unused + true, // exclusive + false, // no-wait + nil, // arguments ) if err != nil { return nil, err @@ -69,7 +69,7 @@ func (t *RabbitTransportClient) Connect(handler UpdateHandler) error { if err != nil { return err } - log.Printf("Connected to rabbit upsert topic: %s", t.OrderTopic) + log.Printf("Connected to rabbit order topic: %s", t.OrderTopic) go func(msgs <-chan amqp.Delivery) { for d := range msgs {