log when we receive notifications

Author: Ryan R. Smith

changelog

@@ -1,3 +1,7 @@
+Version 1.0.0rc1
+- Removed json gem and relying on ruby 1.9.2's stdlib
+- Added better documentation
+
 Version 0.3.6pre
 - Added listen/notify support configured by $QC_LISTENING_WORKER otherwise uses Kernel.sleep()
 

lib/queue_classic/database.rb

@@ -50,7 +50,7 @@ def drain_notify
 
     def wait_for_notify(t)
       log("waiting for notify timeout=#{t}")
-      connection.wait_for_notify(t)
+      connection.wait_for_notify(t) {|event, pid, msg| log("received notification #{event}")}
       log("done waiting for notify")
     end
 

lib/queue_classic/worker.rb

@@ -113,7 +113,7 @@ def wait(t)
       if can_listen?
         log("worker waiting on LISTEN")
         @queue.database.listen
-        @queue.database.wait_for_notify(t) { log("message received") }
+        @queue.database.wait_for_notify(t)
         @queue.database.unlisten
         @queue.database.drain_notify
         log("worker finished LISTEN")