Class: TransactionalOutbox::Producer::Adapters::Null

Inherits:
Base
  • Object
show all
Defined in:
lib/transactional_outbox/producer/adapters/null.rb

Instance Method Summary collapse

Methods included from InstanceMethods

#initialize

Instance Method Details

#clear_store ⇒ Object 



8
 
# File 'lib/transactional_outbox/producer/adapters/null.rb', line 8

def clear_store = @messages = {}

#close ⇒ Object 



18
 
# File 'lib/transactional_outbox/producer/adapters/null.rb', line 18

def close = true

#messages ⇒ Object 



7
 
# File 'lib/transactional_outbox/producer/adapters/null.rb', line 7

def messages = @messages ||= {}

#produce_batch(queue, events) ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/transactional_outbox/producer/adapters/null.rb', line 10

def produce_batch(queue, events)
  msg = messages[queue] ||= []

  msg.concat(events)

  TransactionalOutbox.config.logger&.info("Batch produced")
end