Class: Wisper::ActiveJobBroadcaster

Inherits:
Object
  • Object
show all
Defined in:
lib/wisper_plus.rb

Defined Under Namespace

Classes: Wrapper

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.registerObject



80
81
82
83
84
85
# 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

Instance Method Details

#broadcast(subscriber, publisher, event, args) ⇒ Object



52
53
54
55
56
# 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