class Eventsourcer::BrokerFactory

Public Class Methods

build() click to toggle source
# File lib/eventsourcer/broker_factory.rb, line 3
def self.build
  raise Eventsourcer::Errors::BrokerNotConfiguredError unless Eventsourcer.configuration
  return fetch_broker_klass(Eventsourcer.configuration.broker)
end
fetch_broker_klass(configured_broker) click to toggle source
# File lib/eventsourcer/broker_factory.rb, line 8
def self.fetch_broker_klass(configured_broker)
  if configured_broker == :kafka
    return Eventsourcer::Brokers::KafkaBroker
  else
    raise Eventsourcer::Errors::BrokerNotFound
  end
end