lib/openwfe/expool/threadedexpstorage.rb in openwferu-0.9.16 vs lib/openwfe/expool/threadedexpstorage.rb in openwferu-0.9.17

@@ -59,34 +59,22 @@
         #
         def stop
 
             get_scheduler.unschedule(@thread_id) if @thread_id
 
-            process_queue()
+            process_queue
                 #
                 # flush every remaining events (especially the :delete ones)
         end
 
         #
-        # calls process_queue() before the call the super class each_of_kind()
-        # method
-        #
-        def each_of_kind (kind, &block)
-
-            #ldebug { "each_of_kind()" }
-
-            process_queue()
-            super
-        end
-
-        #
         # calls process_queue() before the call the super class each()
-        # method
+        # method.
         #
-        def each (wfid_prefix=nil, &block)
+        def find_expressions (options)
 
-            process_queue()
+            process_queue
             super
         end
 
         protected
 
@@ -177,14 +165,14 @@
             #
             def observe_expool
 
                 get_expression_pool.add_observer(:update) do |event, fei, fe|
                     ldebug { ":update  for #{fei.to_debug_s}" }
-                    queue(event, fei, fe)
+                    queue event, fei, fe
                 end
                 get_expression_pool.add_observer(:remove) do |event, fei|
                     ldebug { ":remove  for #{fei.to_debug_s}" }
-                    queue(event, fei)
+                    queue event, fei
                 end
             end
     end
 end