diff --git a/domains/communication/lib/communication.rb b/domains/communication/lib/communication.rb index 9395de78..7dc2da65 100644 --- a/domains/communication/lib/communication.rb +++ b/domains/communication/lib/communication.rb @@ -74,10 +74,10 @@ def read(message_id) apply MessageRead.new(data: { message_id: message_id }) end - def apply_message_sent(_) + on MessageSent do |_| end - def apply_message_read(_) + on MessageRead do |_| end end end diff --git a/infra/lib/infra/event_store.rb b/infra/lib/infra/event_store.rb index fe6af941..cb399a6f 100644 --- a/infra/lib/infra/event_store.rb +++ b/infra/lib/infra/event_store.rb @@ -19,7 +19,7 @@ def self.default_mapper def self.in_memory new( RubyEventStore::Client.new( - repository: RubyEventStore::InMemoryRepository.new(ensure_supported_any_usage: true) + repository: RubyEventStore::InMemoryRepository.new ) ) end @@ -27,7 +27,7 @@ def self.in_memory def self.in_memory_rails new( RailsEventStore::Client.new( - repository: RubyEventStore::InMemoryRepository.new(ensure_supported_any_usage: true) + repository: RubyEventStore::InMemoryRepository.new ) ) end