class RFlow::Broker
A message broker process to mediate messages along a connection. The broker runs in a child process and will not return from {spawn!}.
Public Class Methods
build(config)
click to toggle source
Build the broker from the connection configuration. Only supports {RFlow::Configuration::ZMQStreamer} configurations. @param config [RFlow::Configuration::ZMQStreamer] the connection configuration @return [RFlow::Connections::ZMQStreamer]
# File lib/rflow/broker.rb, line 12 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