# File lib/ruote/worker.rb, line 629 def <<(msg) if msg['put_at'].nil? puts '-' * 80 puts "msg missing 'put_at':" pp msg puts '-' * 80 end @msgs << { 'processed_at' => Ruote.now_to_utc_s, 'wait_time' => Time.now - Time.parse(msg['put_at']) #'action' => msg['action'] } save if Time.now > @last_save + 60 end