workqueue.rb in openwferu-0.9.11

- old
+ new

@@ -58,12 +58,12 @@
             @workqueue = []
             @workqueue_frequency = 0
 
             OpenWFE::call_in_thread "expression_pool", self do
                 while true
-                    sleep @workqueue_frequency
                     break if @workqueue_frequency == nil
+                    sleep @workqueue_frequency
                     do_process_workqueue
                 end
             end
         end
 
@@ -139,20 +139,14 @@
             end
 
             #ldebug { "do_process_workqueue() #{q.size} items to process" }
 
             q.each do |elt|
-                begin
 
-                    do_process_workelement elt
-
-                rescue Exception => e
-
-                    lwarn do
-                        "#{self.service_name} caught an exception\n" + 
-                        OpenWFE::exception_to_s(e)
-                    end
-                end
+                do_process_workelement elt
+                    #
+                    # exception management is now done in the 
+                    # do_process_workelement method
             end
         end
 
         protected
 