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