lib/advanced_sneakers_activejob/publisher.rb in advanced-sneakers-activejob-0.2.2 vs lib/advanced_sneakers_activejob/publisher.rb in advanced-sneakers-activejob-0.2.3

@@ -168,12 +168,12 @@
       republish_delayed_exchange.publish message, properties.to_h.merge(routing_key: return_info.routing_key)
     end
 
     def delayed_queue_name(delay:)
       [
-        config_delayed_queue_prefix,
-        delay
-      ].join(':')
+        ::ActiveJob::Base.queue_name_prefix,
+        [config_delayed_queue_prefix, delay].join(':')
+      ].compact.join(::ActiveJob::Base.queue_name_delimiter)
     end
 
     def create_delayed_queue_and_binding(queue_name:, delay:)
       queue_arguments = {
         'x-queue-mode' => 'lazy', # tell RabbitMQ not to use RAM for this queue as it won't be consumed