Class: Kymera::ResultsBus

Inherits:
Object
  • Object
show all
Defined in:
lib/kymera/results_bus.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ResultsBus

Returns a new instance of ResultsBus.



8
9
10
11
12
13
 
# File 'lib/kymera/results_bus.rb', line 8

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

Instance Method Details

#start_bus ⇒ Object 



15
16
17
18
 
# File 'lib/kymera/results_bus.rb', line 15

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