[#71]: fix: ask->ack typo

roadrunner-server · May 20, 2023 · dac4ca8 · dac4ca8
2 parents 8f628c7 + 2cacf9e
commit dac4ca8
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/amqpjobs/config.go b/amqpjobs/config.go
@@ -32,7 +32,7 @@ const (
 	durable       string = "durable"
 	deleteOnStop  string = "delete_queue_on_stop"
 	priority      string = "priority"
-	multipleAsk   string = "multiple_ask"
+	multipleAck   string = "multiple_ack"
 	requeueOnFail string = "requeue_on_fail"
 
 	// new in 2.12
@@ -75,7 +75,7 @@ type config struct {
 	Exclusive         bool   `mapstructure:"exclusive"`
 	Durable           bool   `mapstructure:"durable"`
 	DeleteQueueOnStop bool   `mapstructure:"delete_queue_on_stop"`
-	MultipleAck       bool   `mapstructure:"multiple_ask"`
+	MultipleAck       bool   `mapstructure:"multiple_ack"`
 	RequeueOnFail     bool   `mapstructure:"requeue_on_fail"`
 
 	// new in 2.12.1

diff --git a/amqpjobs/driver.go b/amqpjobs/driver.go
@@ -271,7 +271,7 @@ func FromPipeline(tracer *sdktrace.TracerProvider, pipeline jobs.Pipeline, log *
 		durable:           pipeline.Bool(durable, false),
 		deleteQueueOnStop: pipeline.Bool(deleteOnStop, false),
 		exclusive:         pipeline.Bool(exclusive, false),
-		multipleAck:       pipeline.Bool(multipleAsk, false),
+		multipleAck:       pipeline.Bool(multipleAck, false),
 		requeueOnFail:     pipeline.Bool(requeueOnFail, false),
 
 		// new in 2.12

diff --git a/amqpjobs/item.go b/amqpjobs/item.go
@@ -63,7 +63,7 @@ type Options struct {
 
 	// delayed jobs TODO(rustatian): figure out how to get stats from the DLX
 	delayed     *int64
-	multipleAsk bool
+	multipleAck bool
 	requeue     bool
 }
 
@@ -121,7 +121,7 @@ func (i *Item) Ack() error {
 	if i.Options.Delay > 0 {
 		atomic.AddInt64(i.Options.delayed, ^int64(0))
 	}
-	return i.Options.ack(i.Options.multipleAsk)
+	return i.Options.ack(i.Options.multipleAck)
 }
 
 func (i *Item) Nack() error {
@@ -195,7 +195,7 @@ func (d *Driver) fromDelivery(deliv amqp.Delivery) (*Item, error) {
 					nack:        deliv.Nack,
 					requeueFn:   d.handleItem,
 					delayed:     d.delayed,
-					multipleAsk: false,
+					multipleAck: false,
 					requeue:     false,
 				},
 			}, nil
@@ -272,7 +272,7 @@ func (d *Driver) unpack(deliv amqp.Delivery) (*Item, error) {
 	item := &Item{
 		Payload: bytesToStr(deliv.Body),
 		Options: &Options{
-			multipleAsk: d.multipleAck,
+			multipleAck: d.multipleAck,
 			requeue:     d.requeueOnFail,
 			requeueFn:   d.handleItem,
 			Queue:       d.queue,