lib/fnordmetric/worker.rb in fnordmetric-0.6.2 vs lib/fnordmetric/worker.rb in fnordmetric-0.6.3
- old
+ new
@@ -20,10 +20,10 @@
def tick
@redis.blpop(queue_key, 0).callback do |list, event_id|
@redis.get(event_key(event_id)).callback do |event_data|
process_event(event_id, event_data) if event_data
- FnordMetric.log("oops, lost an event :(") unless event_data
+ FnordMetric.log("event_lost: event_data not found for event-id '#{event_id}'") unless event_data
EM.next_tick(&method(:tick))
@redis.hincrby(stats_key, :events_processed, 1)
end
end
end