diff --git a/workers.go b/workers.go index 9fb286d..bd038b2 100644 --- a/workers.go +++ b/workers.go @@ -34,13 +34,13 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Connected to RabbitMQ") log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name : %s.\n", s.MQQueue.Name) m, err := s.MQChannel.Consume( - s.Queue, // queue - "", // consumer - true, // auto-ack - false, // exclusive - false, // no-local - false, // no-wait - nil, // args + s.MQQueue.Name, // queue + "", // consumer + true, // auto-ack + false, // exclusive + false, // no-local + false, // no-wait + nil, // args ) for d := range m { log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Received a message: %s", string(d.Body))