lib/mosql/streamer.rb in mosql-0.4.0 vs lib/mosql/streamer.rb in mosql-0.4.1

@@ -168,10 +168,10 @@
     def optail
       tail_from = options[:tail_from]
       if tail_from.is_a? Time
         tail_from = tailer.most_recent_position(tail_from)
       end
-      tailer.tail(:from => tail_from)
+      tailer.tail(:from => tail_from, :filter => options[:oplog_filter])
       until @done
         tailer.stream(1000) do |op|
           handle_op(op)
         end
       end