Class: MongoDelta::Stream

Inherits:
Object
  • Object
show all
Includes:
Logging
Defined in:
lib/mongo_delta/stream.rb

Instance Method Summary collapse

Methods included from Logging

#logger, setup_logger

Constructor Details

#initialize(config) ⇒ Stream

Returns a new instance of Stream.



11
12
13
14
15
16
17
 
# File 'lib/mongo_delta/stream.rb', line 11

def initialize(config)
  @config = config
  @tailer = Mongoriver::PersistentTailer.new([@config.source], :existing, @config.service, :db => @config.db)
  @agent  = MongoDelta::Agent.new(:ignore_errors => config.ignore_errors)
  @stream = Mongoriver::Stream.new(@tailer, @agent)
  setup_outlets
end

Instance Method Details

#run(ts = nil) ⇒ Object 



19
20
21
22
23
 
# File 'lib/mongo_delta/stream.rb', line 19

def run(ts=nil)
  register_signal_handlers
  logger.info "Starting stream"
  @stream.run_forever(ts)
end