Contents

#!/usr/bin/env ruby
require "jflow"
require "optparse"

opts = {:file => "worker.json"}
OptionParser.new do |opt|
  opt.on('-f filename') { |o| opts[:file] = o }
end.parse!

configuration = JSON.parse(File.read(opts[:file]))

cli = JFlow::Cli.new(configuration)

["INT", "TERM"].each do |signal|
  Signal.trap(signal) do
    cli.shutdown_workers
  end
end

cli.start_workers

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
jflow-0.3.2	bin/jflow_worker
jflow-0.3.1	bin/jflow_worker
jflow-0.3.0	bin/jflow_worker