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

Version Path
eventus-0.6.7 lib/eventus.rb
eventus-0.6.6 lib/eventus.rb
eventus-0.6.5 lib/eventus.rb
eventus-0.6.4 lib/eventus.rb
eventus-0.6.3 lib/eventus.rb
eventus-0.6.2 lib/eventus.rb
eventus-0.6.1 lib/eventus.rb
eventus-0.6.0 lib/eventus.rb
eventus-0.5.1 lib/eventus.rb
eventus-0.5.0 lib/eventus.rb