lib/pigato/worker.rb in pigato-0.2.8 vs lib/pigato/worker.rb in pigato-0.2.9
- old
+ new
@@ -23,10 +23,10 @@
def reply reply
reply = [@reply_to, '', @reply_rid, '0'].concat([Oj.dump(reply)])
send_to_broker Pigato::W_REPLY, reply
end
- def recv reply
+ def recv
loop do
@reply_rid = nil
@reply_to = nil
@reply_service = nil