diff --git a/backends/rabbitmq/rabbitmq.go b/backends/rabbitmq/rabbitmq.go index 088ab238..226e9fee 100644 --- 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 {