Hello David,
I found the cause of the problem.
The fix replaces:
---8<---
def get_msgs
msgs = []
while (doc = @redis.lpop('msgs')) and (msgs.size < 21)
msgs << from_json(doc)
end
msgs
end
--->8---
with:
---8<---
def get_msgs
doc = @redis.lpop('msgs')
doc ? [ from_json(doc) ] : []
end
--->8---
Usually (at low loads), the 21 limit is never reached. At high loads, the
limit is reached easily, dropping 1 message in 21.
https://github.com/jmettraux/ruote-redis/commit/8b5e847874fb13753541e197de806ba312e739c8
I'm sorry for all the time you wasted because of my stupidity.
--
John Mettraux - http://lambda.io/processi
--
you received this message because you are subscribed to the "ruote users" group.
to post : send email to [email protected]
to unsubscribe : send email to [email protected]
more options : http://groups.google.com/group/openwferu-users?hl=en
