chore: upgrade dependency

Signed-off-by: Bo-Yi.Wu <[email protected]>

Author: appleboy

.github/workflows/go.yml

@@ -14,7 +14,7 @@ jobs:
       - name: Setup golangci-lint
         uses: golangci/golangci-lint-action@v3
         with:
-          version: v1.45.0
+          version: v1.49.0
           args: --verbose
 
   # Label of the container job

Makefile

@@ -1,5 +1,10 @@
+GO ?= go
+
 test:
-	go test -v -cover -covermode=atomic -coverprofile=coverage.out
+	$(GO) test -v -cover -covermode=atomic -coverprofile=coverage.out ./...
+
+upgrade:
+	$(GO) get -u ./...
 
 .PHONY: reset
 reset:

go.mod

@@ -4,7 +4,7 @@ go 1.18
 
 require (
 	github.com/golang-queue/queue v0.1.3
-	github.com/rabbitmq/amqp091-go v1.4.0
+	github.com/rabbitmq/amqp091-go v1.5.0
 	github.com/stretchr/testify v1.8.0
 	go.uber.org/goleak v1.1.12
 )

go.sum

@@ -13,8 +13,8 @@ github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/rabbitmq/amqp091-go v1.4.0 h1:T2G+J9W9OY4p64Di23J6yH7tOkMocgnESvYeBjuG9cY=
-github.com/rabbitmq/amqp091-go v1.4.0/go.mod h1:JsV0ofX5f1nwOGafb8L5rBItt9GyhfQfcJj+oyz0dGg=
+github.com/rabbitmq/amqp091-go v1.5.0 h1:VouyHPBu1CrKyJVfteGknGOGCzmOz0zcv/tONLkb7rg=
+github.com/rabbitmq/amqp091-go v1.5.0/go.mod h1:JsV0ofX5f1nwOGafb8L5rBItt9GyhfQfcJj+oyz0dGg=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

rabbitmq.go

@@ -182,7 +182,8 @@ func (w *Worker) Queue(job core.QueuedMessage) error {
 		return queue.ErrQueueShutdown
 	}
 
-	err := w.channel.Publish(
+	err := w.channel.PublishWithContext(
+		context.Background(),
 		w.opts.exchangeName, // exchange
 		w.opts.routingKey,   // routing key
 		false,               // mandatory