[fix] Manually mark queue as done after task finishes. Now we dont lose task, even if worker crash.

queue/consumer/test_worker.go

@@ -20,4 +20,5 @@ func callback(d amqp.Delivery) {
 	log.Println("Received message: ", string(d.Body))
 	time.Sleep(5 * time.Second)
 	log.Println("Finished!")
+	d.Ack(false)
 }

queue/rabbitmq.go

@@ -84,7 +84,7 @@ func (a *AMQP) Consume(queueName string, callback func(d amqp.Delivery)) {
 	msgs, a.err = a.chn.Consume(
 		queueName, // queue
 		"",        // consumer
-		true,      // auto-ack
+		false,     // auto-ack
 		false,     // exclusive
 		false,     // no-local
 		false,     // no-wait