diff options
Diffstat (limited to 'lib/collector/event_queue.rb')
| -rw-r--r-- | lib/collector/event_queue.rb | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/collector/event_queue.rb b/lib/collector/event_queue.rb index 3851d82..936263b 100644 --- a/lib/collector/event_queue.rb +++ b/lib/collector/event_queue.rb @@ -93,8 +93,10 @@ module Collector private def cache(object) if id = object[:identifier] - unless @dalli.get(id) - @dalli.set(id, true) + key, val = id.split("#", 2) + cur = @dalli.get(id) + if !cur || (val && (cur <=> val) == -1) # not found or new + @dalli.set(key, true || value) yield end else |