Class: Umbra::Subscriber

Inherits:

Object

• Object
• Umbra::Subscriber

Defined in:

lib/umbra/subscriber.rb

Instance Method Summary

• #initialize(worker) ⇒ Subscriber constructor

  A new instance of Subscriber.

• #start ⇒ Object

Constructor Details

#initialize(worker) ⇒ Subscriber

Returns a new instance of Subscriber.

# File 'lib/umbra/subscriber.rb', line 3

def initialize(worker)
  @worker = worker
end

Instance Method Details

#start ⇒ Object

# File 'lib/umbra/subscriber.rb', line 7

def start
  Umbra.redis.subscribe(Umbra::CHANNEL) do |on|
    on.message do |_, message|
      @worker.call(MultiJson.load(message))
    end
  end
end