add dequeue method check to add_queue

ManageIQ · Oct 3, 2023 · 104a16b · 104a16b
1 parent 918529a
commit 104a16b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/app/models/ems_event.rb b/app/models/ems_event.rb
@@ -104,7 +104,7 @@ def self.bottleneck_event_groups
   end
 
   def self.add_queue(meth, ems_id, event)
-    if MiqQueue.messaging_client('event_handler').present?
+    if MiqQueue.messaging_client('event_handler').present? && MiqEventHandler.worker_settings[:dequeue_method] != "drb"
       MiqQueue.messaging_client('event_handler').publish_topic(
         :service => "manageiq.#{MiqEventHandler.default_queue_name}",
         :sender  => ems_id,