Sha256: 42fde0998cd7e99e57bf79c21c0e8e56c51ea58d5475e10823b8245325ecbda7
Contents?: true
Size: 817 Bytes
Versions: 10
Compression:
Stored size: 817 Bytes
Contents
require 'logger'
module Eventus
autoload :Serializers, 'eventus/serializers'
autoload :Dispatchers, 'eventus/dispatchers'
autoload :Persistence, 'eventus/persistence'
autoload :VERSION, 'eventus/version'
class << self
def persistence
@persistence ||= Eventus::Persistence::InMemory.new
end
def persistence=(val)
@persistence = val
end
def dispatcher
@dispatcher ||= Eventus::Dispatchers::Synchronous.new(persistence)
end
def dispatcher=(val)
@dispatcher = val
end
def logger
return @logger if @logger
@logger ||= Logger.new(STDOUT)
@logger.level = Logger::WARN
@logger
end
def logger=(val)
@logger = val
end
end
end
%w{stream errors aggregate_root consumer}.each { |r| require "eventus/#{r}" }
Version data entries
10 entries across 10 versions & 1 rubygems