repain broken amqp specs

cloudamqp · Nov 4, 2024 · eab1b3b · eab1b3b
1 parent 5732543
commit eab1b3b
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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