diff --git a/lib/postzord/dispatcher.rb b/lib/postzord/dispatcher.rb index a3b986b84..c5cfa534b 100644 --- a/lib/postzord/dispatcher.rb +++ b/lib/postzord/dispatcher.rb @@ -40,6 +40,11 @@ class Postzord::Dispatcher if opts[:additional_subscribers].present? opts[:additional_subscribers] = [*opts[:additional_subscribers]].map(&:id) end + + if opts[:to].present? + opts[:to] = [opts[:to]].flatten(1).map {|e| e.respond_to?(:id) ? e.id : e } + end + Workers::DeferredDispatch.perform_async(user.id, object.class.to_s, object.id, opts) end