From f400b712a2e2deb3e64aa1fe369ddaf9847721af Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Fri, 10 Jan 2025 17:27:04 +0100 Subject: [PATCH] fixup! refactor --- src/lavinmq/amqp/queue/queue.cr | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/lavinmq/amqp/queue/queue.cr b/src/lavinmq/amqp/queue/queue.cr index d7a8301b10..d836b8c604 100644 --- a/src/lavinmq/amqp/queue/queue.cr +++ b/src/lavinmq/amqp/queue/queue.cr @@ -155,10 +155,10 @@ module LavinMQ::AMQP private def make_data_dir : String data_dir = if durable? - File.join(@vhost.data_dir, Digest::SHA1.hexdigest @name) - else - File.join(@vhost.data_dir, "transient", Digest::SHA1.hexdigest @name) - end + File.join(@vhost.data_dir, Digest::SHA1.hexdigest @name) + else + File.join(@vhost.data_dir, "transient", Digest::SHA1.hexdigest @name) + end if Dir.exists? data_dir # delete left over files from transient queues unless durable?