CL-Softwares
/
rabbitmq-amqp-go-client
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

more tests (#31) 

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
This commit is contained in:
Gabriele Santomaggio 2025-02-18 10:28:49 +01:00 committed by GitHub
parent b108942f04
commit 4f689b7546
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
pkg/rabbitmqamqp/amqp_queue_test.go
View File

@ -45,7 +45,6 @@ var _ = Describe("AMQP Queue test ", func() {
It("AMQP Queue Declare With Parameters and Get/Delete should succeed", 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") var queueName = generateName("AMQP Queue Declare With Parameters and Delete should succeed")
queueInfo, err := management.DeclareQueue(context.TODO(), &ClassicQueueSpecification{ queueInfo, err := management.DeclareQueue(context.TODO(), &ClassicQueueSpecification{
Name: queueName, Name: queueName,
IsAutoDelete: true, IsAutoDelete: true,
@ -139,6 +138,30 @@ var _ = Describe("AMQP Queue test ", func() {
err = management.DeleteQueue(context.TODO(), queueName) err = management.DeleteQueue(context.TODO(), queueName)
Expect(err).To(BeNil()) 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))
}) })