lib/zk/message_queue.rb in zk-1.2.0 vs lib/zk/message_queue.rb in zk-1.3.0

@@ -118,12 +118,20 @@
         lock = @zk.locker("#{full_queue_path}/#{path}")
         lock.lock!    # XXX(slyphon): should this be a blocking lock?
         locks << lock
       end
       children.each do |path|
-        @zk.delete("#{full_queue_path}/#{path}") rescue ZK::Exceptions::NoNode
+        begin
+          @zk.delete("#{full_queue_path}/#{path}") 
+        rescue ZK::Exceptions::NoNode
+        end
       end
-      @zk.delete(full_queue_path) rescue ZK::Exceptions::NoNode
+
+      begin
+        @zk.delete(full_queue_path) 
+      rescue ZK::Exceptions::NoNode
+      end
+
       locks.each do |lock|
         lock.unlock!
       end
     end