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
 	)

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,7 @@ func main() {`
`35`	`35`	`failOnError(err, "Failed to declare a queue")`
`36`	`36`
`37`	`37`	`err = ch.Qos(`
`38`		`- 3, // prefetch count`
	`38`	`+ 1, // prefetch count`
`39`	`39`	`0, // prefetch size`
`40`	`40`	`false, // global`
`41`	`41`	`)`