Contents

require_relative '../../lib/kymera'
threads = []

trap('INT') do
  threads.each do |thread|
    thread.kill
  end unless threads.empty?
  @close = true
end

#Results bus thread
threads << Thread.new {
  # bus = Kymera::ResultsBus.new('tcp://*:7000', 'tcp://*:7001')
  # bus.start_bus
  Kymera.start_bus
}

#Broker thread
threads << Thread.new {
  # broker = Kymera::Broker.new('tcp://*:5550', 'tcp://*:5551', 'tcp://*:5552', 20)
  # broker.start_broker
  Kymera.start_broker
}

#Results collector thread
threads << Thread.new {
  # results_collector = Kymera::TestResultsCollector.new('tcp://*:5556', 'tcp://127.0.0.1:7000')
  # results_collector = Kymera::TestResultsCollector.new('tcp://*:5556', 'tcp://10.6.49.60:7000')
  # results_collector.listen
  Kymera.start_collector
}

loop do
  raise SystemExit if @close
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
kymera-0.1.7	lib/spec/startup_broker_bus_collector_spec.rb
kymera-0.1.6	lib/spec/startup_broker_bus_collector_spec.rb
kymera-0.1.5	lib/spec/startup_broker_bus_collector_spec.rb
kymera-0.1.4	lib/spec/startup_broker_bus_collector_spec.rb
kymera-0.1.3	lib/spec/startup_broker_bus_collector_spec.rb
kymera-0.1.2	lib/spec/startup_broker_bus_collector_spec.rb
kymera-0.1.1	lib/spec/startup_broker_bus_collector_spec.rb