Class: RFlow::Broker
- Inherits:
-
ChildProcess
- Object
- ChildProcess
- RFlow::Broker
- 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
Instance Attribute Summary
Attributes inherited from ChildProcess
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 |