class Wisper::ActiveJobBroadcaster

Public Class Methods

register() click to toggle source
# File lib/wisper_plus.rb, line 80
def self.register
  Wisper.configure do |config|
    config.broadcaster :active_job, ActiveJobBroadcaster.new
    config.broadcaster :async,      ActiveJobBroadcaster.new
  end
end

Public Instance Methods

broadcast(subscriber, publisher, event, args) click to toggle source
# File lib/wisper_plus.rb, line 52
def broadcast(subscriber, publisher, event, args)
  # Turn objects in args into GlobalID strings
  args = args.map { |e| e.respond_to?(:to_global_id) ? e.to_global_id.to_s : e }
  Wrapper.perform_later(subscriber.class.name, event, JSON.dump(args))
end