Fix bug stripe-archive#1

bearfact · Sep 5, 2014 · e673c10 · e673c10
1 parent 439ee9f
commit e673c10
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/mongoriver/abstract_persistent_tailer.rb b/lib/mongoriver/abstract_persistent_tailer.rb
@@ -17,7 +17,7 @@ def initialize(upstream, type, opts={})
 
       @last_saved       = {}
       @batch            = opts[:batch]
-      @last_read        = read_state
+      @last_read        = read_state || {}
       @save_frequency   = opts[:save_frequency] || DEFAULT_SAVE_FREQUENCY
     end
 
@@ -43,6 +43,7 @@ def stream(limit=nil)
 
       if !found_entry && !entries_left
         @last_read['time'] = start_time
+        @last_read['placeholder'] = most_recent_position(start_time)
         maybe_save_state unless @batch
       end