Module: Eventus

Defined in:
lib/eventus.rb,
lib/eventus/errors.rb,
lib/eventus/stream.rb,
lib/eventus/version.rb,
lib/eventus/consumer.rb,
lib/eventus/dispatchers.rb,
lib/eventus/persistence.rb,
lib/eventus/serializers.rb,
lib/eventus/aggregate_root.rb,
lib/eventus/persistence/mongo.rb,
lib/eventus/persistence/redis.rb,
lib/eventus/persistence/sequel.rb,
lib/eventus/serializers/marshal.rb,
lib/eventus/serializers/msgpack.rb,
lib/eventus/persistence/in_memory.rb,
lib/eventus/dispatchers/synchronous.rb,
lib/eventus/persistence/kyotocabinet.rb

Defined Under Namespace

Modules: AggregateRoot, Consumer, Dispatchers, Persistence, Serializers Classes: ConcurrencyError, ConflictError, ConnectionError, Stream

Constant Summary collapse

VERSION = 
"0.6.7"

Class Method Summary collapse

Class Method Details

.dispatcher ⇒ Object 



19
20
21
 
# File 'lib/eventus.rb', line 19

def dispatcher
  @dispatcher ||= Eventus::Dispatchers::Synchronous.new(persistence)
end

.dispatcher=(val) ⇒ Object 



23
24
25
 
# File 'lib/eventus.rb', line 23

def dispatcher=(val)
  @dispatcher = val
end

.logger ⇒ Object 



27
28
29
30
31
32
 
# File 'lib/eventus.rb', line 27

def logger
  return @logger if @logger
  @logger ||= Logger.new(STDOUT)
  @logger.level = Logger::WARN
  @logger
end

.logger=(val) ⇒ Object 



34
35
36
 
# File 'lib/eventus.rb', line 34

def logger=(val)
  @logger = val
end

.persistence ⇒ Object 



11
12
13
 
# File 'lib/eventus.rb', line 11

def persistence
  @persistence ||= Eventus::Persistence::InMemory.new
end

.persistence=(val) ⇒ Object 



15
16
17
 
# File 'lib/eventus.rb', line 15

def persistence=(val)
  @persistence = val
end