Contents

module Weeter
  module Plugins
    module Notification
      class Resque
        include Weeter::Plugins::Net::Redis
        
        def initialize(client_app_config)
          @config = client_app_config
        end

        def publish_tweet(tweet_item)
          resque_job = %Q|{"class":"WeeterPublishTweetJob","args":[#{tweet_item.to_json}]}|
          Weeter.logger.info("Publishing tweet #{tweet_item['id']} from user #{tweet_item['user']['id_str']}: #{tweet_item['text']}")
          enqueue(resque_job)
        end

        def delete_tweet(tweet_item)
          resque_job = %Q|{"class":"WeeterDeleteTweetJob","args":[#{tweet_item.to_json}]}|
          Weeter.logger.info("Deleting tweet #{tweet_item['id']} for user #{tweet_item['user']['id_str']}")
          enqueue(resque_job)
        end

      protected
      
        def redis
          @redis ||= create_redis_client
        end
      
        def enqueue(job)
          redis.rpush(queue_key, job)
        end

        def queue_key
          "resque:queue:#{@config.queue}"
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
weeter-0.11.0	lib/weeter/plugins/notification/resque.rb
weeter-0.10.0	lib/weeter/plugins/notification/resque.rb
weeter-0.9.2	lib/weeter/plugins/notification/resque.rb
weeter-0.9.1	lib/weeter/plugins/notification/resque.rb
weeter-0.9.0	lib/weeter/plugins/notification/resque.rb