Class: RFlow::Broker

Inherits:
ChildProcess show all
Defined in:
lib/rflow/broker.rb

Overview

A message broker to mediate messages along a connection. The broker runs in a child process and will not return from spawn!.

Direct Known Subclasses

Connections::ZMQStreamer

Constant Summary

Constants inherited from ChildProcess

ChildProcess::SIGINFO

Instance Attribute Summary

Attributes inherited from ChildProcess

#name, #pid

Class Method Summary collapse

Methods inherited from ChildProcess

#initialize, #run_child_process, #run_process, #shutdown!, #spawn!

Constructor Details

This class inherits a constructor from RFlow::ChildProcess

Class Method Details

.build(config) ⇒ Object 



8
9
10
11
12
13
14
15
 
# File 'lib/rflow/broker.rb', line 8

def build(config)
  case config.class.name
  when 'RFlow::Configuration::ZMQStreamer'
    RFlow::Connections::ZMQStreamer.new(config)
  else
    raise ArgumentError, 'Only ZMQ brokers currently supported'
  end
end