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