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