set prefetch count to 1

2015-08-12 09:32:02 +01:00 · 2015-08-12 09:32:02 +01:00 · 8fdbdae4e7
commit 8fdbdae4e7
parent a2fdf79d5b
1 changed files with 1 additions and 1 deletions
--- 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
 	)