diff --git a/app/models/miq_provision_request.rb b/app/models/miq_provision_request.rb
index 8885fd025787..362264731da7 100644
--- a/app/models/miq_provision_request.rb
+++ b/app/models/miq_provision_request.rb
@@ -73,6 +73,10 @@ def my_role(_action = nil)
     'ems_operations'
   end
 
+  def my_queue_name
+    source.ext_management_system.queue_name_for_ems_operations
+  end
+
   def requested_task_idx
     (1..get_option(:number_of_vms).to_i).to_a
   end
diff --git a/app/models/miq_request_task/state_machine.rb b/app/models/miq_request_task/state_machine.rb
index 40f7a1509b65..c5a776763dee 100644
--- a/app/models/miq_request_task/state_machine.rb
+++ b/app/models/miq_request_task/state_machine.rb
@@ -80,6 +80,7 @@ def requeue_phase
       :deliver_on     => 10.seconds.from_now.utc,
       :zone           => my_zone,
       :role           => my_role,
+      :queue_name     => my_queue_name,
       :tracking_label => tracking_label_id,
       :miq_callback => {:class_name => self.class.name, :instance_id => id, :method_name => :execute_callback}
     )