class Wisper::SidekiqBroadcaster
Attributes
options[R]
Public Class Methods
new(options = {})
click to toggle source
# File lib/wisper/sidekiq.rb, line 10 def initialize(options = {}) @options = options == true ? {} : options end
register()
click to toggle source
# File lib/wisper/sidekiq.rb, line 18 def self.register Wisper.configure do |config| config.broadcaster :sidekiq, Proc.new { |options| SidekiqBroadcaster.new(options) } config.broadcaster :async, Proc.new { |options| SidekiqBroadcaster.new(options) } end end
Public Instance Methods
broadcast(subscriber, publisher, event, args)
click to toggle source
# File lib/wisper/sidekiq.rb, line 14 def broadcast(subscriber, publisher, event, args) subscriber.delay(options).public_send(event, *args) end