Contents

require_relative 'szmq/szmq'
require 'json'

module Kymera

  class ResultsBus

    def initialize
      config = Kymera::Config.new
      @zmq = Kymera::SZMQ.new
      @incoming_socket = @zmq.socket("tcp://*:#{config.result_bus["pub_port"]}", 'xsub')
      @outgoing_socket = @zmq.socket("tcp://*:#{config.result_bus["sub_port"]}", 'xpub')
    end

    def start_bus
      puts "Results bus started..."
      @zmq.start_pub_sub_proxy(@incoming_socket, @outgoing_socket)
    end




  end


end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
kymera-0.1.7	lib/kymera/results_bus.rb
kymera-0.1.6	lib/kymera/results_bus.rb
kymera-0.1.5	lib/kymera/results_bus.rb
kymera-0.1.4	lib/kymera/results_bus.rb
kymera-0.1.3	lib/kymera/results_bus.rb
kymera-0.1.2	lib/kymera/results_bus.rb
kymera-0.1.1	lib/kymera/results_bus.rb
kymera-0.1.0	lib/kymera/results_bus.rb