Module: Resque::Plugins::Pubsub::Subscriber::ClassMethods

Defined in:
lib/resque/plugins/pubsub/subscriber.rb

Instance Method Summary collapse

Instance Method Details

#subscribe(topic, options = {}) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/resque/plugins/pubsub/subscriber.rb', line 12

def subscribe(topic, options={})
  @queue = "fanout:#{topic}"
  reader_method = options[:reader_method] || "read_#{topic}_message"
  module_eval <<-"end_eval"
    def self.perform(message)
      self.send("#{reader_method.to_s}", message)
    end
  end_eval
  options[:namespace] = Resque.redis.namespace
  options[:topic] = topic
  options[:class] = self.to_s
  puts "[#{self.to_s}] subscribing with #{options.inspect}"
  Exchange.redis.sadd(:queues, :subscription_requests)
  Exchange.redis.rpush("queue:subscription_requests", { :class => 'Resque::Plugins::Pubsub::Exchange', :args => [options] }.to_json)      
end