diff --git a/workers.go b/workers.go
index 9a9c5a9..ba5e2f0 100644
--- a/workers.go
+++ b/workers.go
@@ -36,34 +36,32 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Connection address : %p.\n", &s.MQConnection)
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Channel address : %p.\n", &s.MQChannel)
 		log.Printf("MQGetMsgWorker["+strconv.Itoa(id)+"] : Queue name : %s.\n", s.Queue)
-		/*
-			q, err := s.MQChannel.QueueDeclare(
-				s.Queue, // name
-				false,   // durable
-				false,   // delete when unused
-				false,   // exclusive
-				false,   // no-wait
-				nil,     // arguments
+		q, err := s.MQChannel.QueueDeclare(
+			s.Queue, // name
+			false,   // durable
+			false,   // delete when unused
+			false,   // exclusive
+			false,   // no-wait
+			nil,     // arguments
 
-			)
-			m, err := s.MQChannel.Consume(
-				q.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))
-				err = json.Unmarshal(d.Body, &x)
-				logOnError(err, "MQGetMsgWorker["+strconv.Itoa(id)+"] : Can't unmarshal.\n"+string(d.Body))
-				if err == nil {
-					msgs <- x
-				}
+		)
+		m, err := s.MQChannel.Consume(
+			q.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))
+			err = json.Unmarshal(d.Body, &x)
+			logOnError(err, "MQGetMsgWorker["+strconv.Itoa(id)+"] : Can't unmarshal.\n"+string(d.Body))
+			if err == nil {
+				msgs <- x
 			}
-		*/
+		}
 		log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Closing queue.\n")
 		s.Close()
 	}