Class: MessageStore::EventStore::Write

Inherits:
Object
  • Object
show all
Includes:
Write
Defined in:
lib/message_store/event_store/write.rb

Defined Under Namespace

Modules: Assertions

Instance Method Summary collapse

Instance Method Details

#configure(session: nil) ⇒ Object 



8
9
10
 
# File 'lib/message_store/event_store/write.rb', line 8

def configure(session: nil)
  Put.configure(self, session: session)
end

#write(batch, stream_name, expected_version: nil) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/message_store/event_store/write.rb', line 12

def write(batch, stream_name, expected_version: nil)
  logger.trace { "Writing batch (Stream Name: #{stream_name}, Number of Messages: #{batch.count}, Expected Version: #{expected_version.inspect})" }

  position = put.(batch, stream_name, expected_version: expected_version)

  last_position = position + (batch.count - 1)

  logger.debug { "Wrote batch (Stream Name: #{stream_name}, Number of Messages: #{batch.count}, Expected Version: #{expected_version.inspect}, Last Position: #{last_position})" }

  last_position
end