lib/weeter/plugins/notification/resque.rb in weeter-0.15.0 vs lib/weeter/plugins/notification/resque.rb in weeter-0.17.0

@@ -7,46 +7,49 @@
         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}]}|
+          resque_job = %Q|{"class":"WeeterPublishTweetJob","args":[#{tweet_item.to_json}],"jid": "#{SecureRandom.hex(12)}"}|
           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}]}|
+          resque_job = %Q|{"class":"WeeterDeleteTweetJob","args":[#{tweet_item.to_json}],"jid": "#{SecureRandom.hex(12)}"}|
           Weeter.logger.info("Deleting tweet #{tweet_item['id']} for user #{tweet_item['user']['id_str']}")
           enqueue(resque_job)
         end
 
         def notify_missed_tweets(tweet_item)
-          resque_job = %Q|{"class":"WeeterMissedTweetsJob","args":[#{tweet_item.to_json}]}|
+          resque_job = %Q|{"class":"WeeterMissedTweetsJob","args":[#{tweet_item.to_json}],"jid": "#{SecureRandom.hex(12)}"}|
           Weeter.logger.info("Notifying of missed tweets (#{tweet_item.missed_tweets_count}).")
           enqueue(resque_job)
         end
 
         def notify_rate_limiting_initiated(tweet_item, limited_keys)
           payload = tweet_item.to_hash.merge(:limited_keys => limited_keys)
           payload_json = MultiJson.encode(payload)
-          resque_job = %Q|{"class":"WeeterRateLimitingInitiatedJob","args":[#{payload_json}]}|
+          resque_job = %Q|{"class":"WeeterRateLimitingInitiatedJob","args":[#{payload_json}],"jid": "#{SecureRandom.hex(12)}"}|
           Weeter.logger.info("Initiated rate limiting with tweet: #{payload_json}")
           enqueue(resque_job)
         end
 
       protected
 
         def redis
-          @redis ||= create_redis_client
+          @redis ||= begin
+            @config.verify_redis_namespace_config
+            create_redis_client
+          end
         end
 
         def enqueue(job)
           redis.rpush(queue_key, job)
         end
 
         def queue_key
-          "resque:queue:#{@config.queue}"
+          "#{@config.redis_namespace}:#{@config.queue}"
         end
       end
     end
   end
 end