Merge branch 'wagslane:main' into main

.github/workflows/tests.yml

@@ -12,10 +12,10 @@ jobs:
       GOPROXY: "https://proxy.golang.org,direct"
 
     steps:
-      - name: Set up Go 1.18
+      - name: Set up Go
         uses: actions/setup-go@v2
         with:
-          go-version: 1.18
+          go-version: "1.20"
         id: go
 
       - name: Check out code into the Go module directory

go.mod

@@ -1,5 +1,5 @@
 module github.com/wagslane/go-rabbitmq
 
-go 1.17
+go 1.20
 
 require github.com/rabbitmq/amqp091-go v1.5.0

internal/channelmanager/safe_wraps.go

@@ -144,7 +144,8 @@ func (chanManager *ChannelManager) PublishSafe(
 	chanManager.channelMux.RLock()
 	defer chanManager.channelMux.RUnlock()
 
-	return chanManager.channel.Publish(
+	return chanManager.channel.PublishWithContext(
+		context.Background(),
 		exchange,
 		key,
 		mandatory,

internal/dispatcher/dispatcher_test.go

@@ -7,9 +7,6 @@ import (
 
 func TestNewDispatcher(t *testing.T) {
 	d := NewDispatcher()
-	if d == nil {
-		t.Error("Dispatcher is nil")
-	}
 	if d.subscribers == nil {
 		t.Error("Dispatcher subscribers is nil")
 	}