Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/env ruby
- require 'rubygems'
- require 'redis'
- class Subscriber
- def initialize
- end
- def redis
- Redis.new(:host => "redis.fotonauts.net", :port => 12430)
- end
- def wait
- redis.subscribe('frontline') do |on|
- on.subscribe do |queue, message|
- puts "Ready to process"
- end
- on.message do |queue, message|
- end
- end
- end
- end
- if __FILE__==$0
- g= Subscriber.new
- g.wait
- end
Add Comment
Please, Sign In to add comment