diff --git a/workers.go b/workers.go index 88e2df3..c31dce4 100644 --- a/workers.go +++ b/workers.go @@ -33,9 +33,10 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) { } //log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Connected to RabbitMQ") log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Session address : %p.\n", &s) + log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue address : %p.\n", &s.MQQueue) /* m, err := s.MQChannel.Consume( - s.Queue, // queue + s.MQQueue.Name, // queue "", // consumer true, // auto-ack false, // exclusive