Set noAck/autoAck to false

bilaljaved · bilaljaved · commit 08825aa34a3e · 2019-11-01T12:13:13.000+01:00
diff --git a/extension/amqp/amqp.go b/extension/amqp/amqp.go
@@ -55,7 +55,7 @@ func DirectQueueConsume(amqpDSN, queue string) (Consume, error) {
 		}
 
 		// Since there can be multiple consumers, fair distribution of deliveries is required
-		deliveries, err := ch.Consume(queue, "", true, false, false, false, nil)
+		deliveries, err := ch.Consume(queue, "", false, false, false, false, nil)
 
 		return conn, deliveries, err
 	}, nil

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ func DirectQueueConsume(amqpDSN, queue string) (Consume, error) {`
`55`	`55`	`}`
`56`	`56`
`57`	`57`	`// Since there can be multiple consumers, fair distribution of deliveries is required`
`58`		`- deliveries, err := ch.Consume(queue, "", true, false, false, false, nil)`
	`58`	`+ deliveries, err := ch.Consume(queue, "", false, false, false, false, nil)`
`59`	`59`
`60`	`60`	`return conn, deliveries, err`
`61`	`61`	`}, nil`