lib/ryespy/notifiers/sidekiq.rb in ryespy-0.6.1 vs lib/ryespy/notifiers/sidekiq.rb in ryespy-0.7.0

@@ -6,12 +6,11 @@
 
 module Ryespy
   module Notifier
     class Sidekiq
       
-      REDIS_NS_RESQUE = 'resque'
-      RESQUE_QUEUE    = 'ryespy'
+      RESQUE_QUEUE = 'ryespy'
       
       def initialize(url = nil)
         begin
           @redis_conn = Ryespy::RedisConn.new(url)
         rescue Errno::ECONNREFUSED, Net::FTPError => e
@@ -30,12 +29,12 @@
       def close
         @redis_conn.close
       end
       
       def notify(job_class, args)
-        @redis_conn.redis.sadd("#{REDIS_NS_RESQUE}:queues", RESQUE_QUEUE)
+        @redis_conn.redis.sadd("#{Ryespy.config.redis_ns_notifiers}queues", RESQUE_QUEUE)
         
-        @redis_conn.redis.rpush("#{REDIS_NS_RESQUE}:queue:#{RESQUE_QUEUE}", {
+        @redis_conn.redis.rpush("#{Ryespy.config.redis_ns_notifiers}queue:#{RESQUE_QUEUE}", {
           # resque
           :class => job_class,
           :args  => args,
           # sidekiq (extra)
           :queue => RESQUE_QUEUE,