Sha256: f5b3bf85f9c5aea57ee43fc036a6158d14fed1523e0a454a14a339bf93dd1c51
Contents?: true
Size: 505 Bytes
Versions: 10
Compression:
Stored size: 505 Bytes
Contents
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
Version data entries
10 entries across 10 versions & 1 rubygems