From 4f689b7546da49b4a8a96f5f659adf2ff6618bf5 Mon Sep 17 00:00:00 2001 From: Gabriele Santomaggio Date: Tue, 18 Feb 2025 10:28:49 +0100 Subject: [PATCH] more tests (#31) Signed-off-by: Gabriele Santomaggio --- pkg/rabbitmqamqp/amqp_queue_test.go | 25 ++++++++++++++++++++++++- 1 file changed, 24 insertions(+), 1 deletion(-) diff --git a/pkg/rabbitmqamqp/amqp_queue_test.go b/pkg/rabbitmqamqp/amqp_queue_test.go index d0f2d26..ace4307 100644 --- a/pkg/rabbitmqamqp/amqp_queue_test.go +++ b/pkg/rabbitmqamqp/amqp_queue_test.go @@ -45,7 +45,6 @@ var _ = Describe("AMQP Queue test ", func() { It("AMQP Queue Declare With Parameters and Get/Delete should succeed", func() { var queueName = generateName("AMQP Queue Declare With Parameters and Delete should succeed") - queueInfo, err := management.DeclareQueue(context.TODO(), &ClassicQueueSpecification{ Name: queueName, IsAutoDelete: true, @@ -139,6 +138,30 @@ var _ = Describe("AMQP Queue test ", func() { err = management.DeleteQueue(context.TODO(), queueName) Expect(err).To(BeNil()) + }) + + It("AMQP Classic should return queue info ", func() { + const queueName = "AMQP Classic should return queue info" + qName := generateName(queueName) + queueInfo, err := management.DeclareQueue(context.TODO(), &ClassicQueueSpecification{ + Name: qName, + MaxPriority: 32, + MaxLengthBytes: CapacityGB(1), + MaxLength: CapacityKB(1024), + IsAutoDelete: false, + }) + + Expect(err).To(BeNil()) + Expect(queueInfo).NotTo(BeNil()) + Expect(queueInfo.Name()).To(Equal(qName)) + Expect(queueInfo.IsDurable()).To(BeTrue()) + Expect(queueInfo.IsAutoDelete()).To(BeFalse()) + Expect(queueInfo.IsExclusive()).To(BeFalse()) + Expect(queueInfo.Type()).To(Equal(Classic)) + qInfoReceived, err := management.QueueInfo(context.TODO(), qName) + Expect(err).To(BeNil()) + Expect(qInfoReceived).To(Equal(queueInfo)) + Expect(management.DeleteQueue(context.TODO(), qName)) })