require 'rflow/child_process'

class RFlow
  # A message broker to mediate messages along a connection.
  # The broker runs in a child process and will not return from spawn!.
  class Broker < ChildProcess
    class << self
      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
    end
  end
end