From eab1b3bd1355412df2deb0c90d5c64d8b068e467 Mon Sep 17 00:00:00 2001 From: Christina Date: Mon, 4 Nov 2024 10:47:10 +0100 Subject: [PATCH] repain broken amqp specs --- src/lavinmq/queue_factory.cr | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/lavinmq/queue_factory.cr b/src/lavinmq/queue_factory.cr index 7dcb7b030b..d20ba37c19 100644 --- a/src/lavinmq/queue_factory.cr +++ b/src/lavinmq/queue_factory.cr @@ -18,7 +18,6 @@ module LavinMQ end private def self.make_durable(vhost, frame) - raise Error::PreconditionFailed.new("Not allowed to use that prefix") if PrefixValidation.invalid?(frame.queue_name) && !mqtt_session?(frame) if prio_queue? frame AMQP::DurablePriorityQueue.new(vhost, frame.queue_name, frame.exclusive, frame.auto_delete, frame.arguments) elsif stream_queue? frame @@ -37,7 +36,6 @@ module LavinMQ end private def self.make_queue(vhost, frame) - raise Error::PreconditionFailed.new("Not allowed to use that prefix") if PrefixValidation.invalid?(frame.queue_name) && !mqtt_session?(frame) if prio_queue? frame AMQP::PriorityQueue.new(vhost, frame.queue_name, frame.exclusive, frame.auto_delete, frame.arguments) elsif stream_queue? frame