Contents

require "rubygems"
require "eventmachine"
require 'em-hiredis'

module Runner

  def self.redis
    @redis ||= EM::Hiredis.connect("redis://localhost:6379")
  end

  def self.next
    redis.blpop('fnordmetric-queue', 0).callback do |list, data|
      puts data
      EM.next_tick(&method(:next))
    end
  end

end


module Ticker

  def self.tick
    EM.defer(proc { print '.'; sleep 1; }, proc{ EM.next_tick(&method(:tick)) })
    #EM.next_tick(&method(:next))    
  end

end

EM.run do
  Ticker.tick
  Runner.next
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fnordmetric-0.5.0	em_runner.rb