lib/ruote/exp/flowexpression.rb in ruote-2.1.3 vs lib/ruote/exp/flowexpression.rb in ruote-2.1.4
- old
+ new
@@ -143,10 +143,18 @@
# apply/reply
#++
def self.do_action (context, msg)
- fexp = fetch(context, msg['fei'])
+ fexp = nil
+
+ 3.times do
+ fexp = fetch(context, msg['fei'])
+ break if fexp
+ sleep 0.028
+ end
+ # this retry system is only useful with ruote-couch
+
fexp.send("do_#{msg['action']}", msg) if fexp
end
def do_apply