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