diff --git a/app/models/job/state_machine.rb b/app/models/job/state_machine.rb index 9a6aa49238e..3a0e3e9d071 100644 --- a/app/models/job/state_machine.rb +++ b/app/models/job/state_machine.rb @@ -51,7 +51,7 @@ def signal(signal, *args) end end - def queue_signal(*args, priority: MiqQueue::NORMAL_PRIORITY, role: nil, deliver_on: nil, server_guid: nil) + def queue_signal(*args, priority: MiqQueue::NORMAL_PRIORITY, role: nil, deliver_on: nil, server_guid: nil, queue_name: nil) MiqQueue.put( :class_name => self.class.name, :method_name => "signal", @@ -59,6 +59,7 @@ def queue_signal(*args, priority: MiqQueue::NORMAL_PRIORITY, role: nil, deliver_ :priority => priority, :role => role, :zone => zone, + :queue_name => queue_name, :task_id => guid, :args => args, :deliver_on => deliver_on,