Contents

module Umbra
  class Subscriber
    def initialize(worker)
      @worker = worker
    end

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

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
umbra-rb-0.3.0.pre	lib/umbra/subscriber.rb
umbra-rb-0.2.0	lib/umbra/subscriber.rb
umbra-rb-0.1.5.pre	lib/umbra/subscriber.rb
umbra-rb-0.1.4.pre	lib/umbra/subscriber.rb
umbra-rb-0.1.3.pre	lib/umbra/subscriber.rb
umbra-rb-0.1.2.pre	lib/umbra/subscriber.rb
umbra-rb-0.1.1.pre	lib/umbra/subscriber.rb
umbra-rb-0.1.0.pre	lib/umbra/subscriber.rb