auto-delete was not being used

streamdal · Sep 14, 2024 · 831853d · 831853d
1 parent 5a01c89
commit 831853d
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/backends/rabbitmq/rabbitmq.go b/backends/rabbitmq/rabbitmq.go
@@ -62,15 +62,16 @@ func (r *RabbitMQ) newRabbitForRead(readArgs *args.RabbitReadArgs) (rabbit.IRabb
 				ExchangeName: readArgs.ExchangeName,
 			},
 		},
-		QueueExclusive: readArgs.QueueExclusive,
-		QueueDurable:   readArgs.QueueDurable,
-		QueueDeclare:   readArgs.QueueDeclare,
-		AutoAck:        readArgs.AutoAck,
-		ConsumerTag:    readArgs.ConsumerTag,
-		UseTLS:         r.connArgs.UseTls,
-		SkipVerifyTLS:  r.connArgs.TlsSkipVerify,
-		Mode:           rabbit.Consumer,
-		QueueArgs:      mapToTable(readArgs.QueueArg),
+		QueueExclusive:  readArgs.QueueExclusive,
+		QueueDurable:    readArgs.QueueDurable,
+		QueueDeclare:    readArgs.QueueDeclare,
+		QueueAutoDelete: readArgs.QueueDelete,
+		AutoAck:         readArgs.AutoAck,
+		ConsumerTag:     readArgs.ConsumerTag,
+		UseTLS:          r.connArgs.UseTls,
+		SkipVerifyTLS:   r.connArgs.TlsSkipVerify,
+		Mode:            rabbit.Consumer,
+		QueueArgs:       mapToTable(readArgs.QueueArg),
 	})
 
 	if err != nil {