update azure to 1.5.1 (#75)

* update azure to 1.5.1

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

* Failing test (#76)

Co-authored-by: Michal Kuratczyk <michal.kuratczyk@broadcom.com>

---------

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
Co-authored-by: Michal Kuratczyk <michal.kuratczyk@broadcom.com>

Author: Gsantomaggio

go.mod

@@ -5,7 +5,7 @@ go 1.23.0
 toolchain go1.24.5
 
 require (
-	github.com/Azure/go-amqp v1.5.0
+	github.com/Azure/go-amqp v1.5.1
 	github.com/golang-jwt/jwt/v5 v5.2.2
 	github.com/google/uuid v1.6.0
 	github.com/onsi/ginkgo/v2 v2.23.4

go.sum

@@ -2,6 +2,8 @@ github.com/Azure/go-amqp v1.4.0 h1:Xj3caqi4comOF/L1Uc5iuBxR/pB6KumejC01YQOqOR4=
 github.com/Azure/go-amqp v1.4.0/go.mod h1:vZAogwdrkbyK3Mla8m/CxSc/aKdnTZ4IbPxl51Y5WZE=
 github.com/Azure/go-amqp v1.5.0 h1:GRiQK1VhrNFbyx5VlmI6BsA1FCp27W5rb9kxOZScnTo=
 github.com/Azure/go-amqp v1.5.0/go.mod h1:vZAogwdrkbyK3Mla8m/CxSc/aKdnTZ4IbPxl51Y5WZE=
+github.com/Azure/go-amqp v1.5.1 h1:WyiPTz2C3zVvDL7RLAqwWdeoYhMtX62MZzQoP09fzsU=
+github.com/Azure/go-amqp v1.5.1/go.mod h1:vZAogwdrkbyK3Mla8m/CxSc/aKdnTZ4IbPxl51Y5WZE=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=

pkg/rabbitmqamqp/amqp_publisher_test.go

@@ -2,6 +2,7 @@ package rabbitmqamqp
 
 import (
 	"context"
+
 	"github.com/Azure/go-amqp"
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
@@ -46,6 +47,22 @@ var _ = Describe("AMQP publisher ", func() {
 		Expect(connection.Close(context.Background())).To(BeNil())
 	})
 
+	It("NewPublisher should fail for a non-existing queue", func() {
+		connection, err := Dial(context.Background(), "amqp://", nil)
+		Expect(err).To(BeNil())
+		Expect(connection).NotTo(BeNil())
+		queueName := generateNameWithDateTime("NonExistingQueue")
+
+		// Try to create a publisher to a queue that doesn't exist
+		// This MUST fail at the NewPublisher step
+		publisher, err := connection.NewPublisher(context.Background(), &QueueAddress{Queue: queueName}, nil)
+		Expect(err).NotTo(BeNil())
+		Expect(err.Error()).To(ContainSubstring("amqp:not-found"))
+		Expect(err.Error()).To(ContainSubstring("no queue"))
+		Expect(publisher).To(BeNil())
+		Expect(connection.Close(context.Background())).To(BeNil())
+	})
+
 	It("publishResult should released to a not existing routing key", func() {
 		eName := generateNameWithDateTime("publishResult should released to a not existing routing key")
 		connection, err := Dial(context.Background(), "amqp://", nil)