Class: Nsqcd::Runner

Inherits:

Object

• Object
• Nsqcd::Runner

Defined in:

lib/nsqcd/runner.rb

Instance Method Summary

• #initialize(worker_classes, opts = {}) ⇒ Runner constructor

  A new instance of Runner.

• #run ⇒ Object
• #stop ⇒ Object

Constructor Details

#initialize(worker_classes, opts = {}) ⇒ Runner

Returns a new instance of Runner.

# File 'lib/nsqcd/runner.rb', line 6

def initialize(worker_classes, opts={})
  @runnerconfig = RunnerConfig.new(worker_classes, opts)
end

Instance Method Details

#run ⇒ Object

# File 'lib/nsqcd/runner.rb', line 10

def run
  @se = ServerEngine.create(nil, WorkerGroup) { @runnerconfig.reload_config! }
  @se.run
end

#stop ⇒ Object

# File 'lib/nsqcd/runner.rb', line 15

def stop
  @se.stop
end