Default whether to notify based on QC::LISTENING_WORKER.

QueueClassic · Aug 1, 2012 · ad504dd · ad504dd · joevandyk · Nov 15, 2012
1 parent f9e8499
commit ad504dd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/queue_classic.rb b/lib/queue_classic.rb
@@ -66,7 +66,7 @@ def self.method_missing(sym, *args, &block)
 
   def self.default_queue
     @default_queue ||= begin
-      Queue.new(QUEUE, LISTENING_WORKER)
+      Queue.new(QUEUE)
     end
   end
 

diff --git a/lib/queue_classic/queue.rb b/lib/queue_classic/queue.rb
@@ -3,7 +3,7 @@ class Queue
 
     attr_reader :name, :chan
 
-    def initialize(name, notify=false)
+    def initialize(name, notify=QC::LISTENING_WORKER)
       @name = name
       @chan = @name if notify
     end