set prefetch count to 1

priviterag · priviterag · commit 8fdbdae4e7df · 2015-08-12T09:32:02.000+01:00
diff --git a/go/worker.go b/go/worker.go
@@ -35,7 +35,7 @@ func main() {
 	failOnError(err, "Failed to declare a queue")
 
 	err = ch.Qos(
-		3,     // prefetch count
+		1,     // prefetch count
 		0,     // prefetch size
 		false, // global
 	)
