Module: RailsEventStore::AsyncHandlerJobIdOnly

Defined in:
lib/rails_event_store/async_handler_helpers.rb

Class Method Summary collapse

Class Method Details

.prepended(host_class) ⇒ Object



45
46
47
# File 'lib/rails_event_store/async_handler_helpers.rb', line 45

def self.prepended(host_class)
  host_class.prepend with_defaults
end

.with(event_store: Rails.configuration.event_store, event_store_locator: nil) ⇒ Object



36
37
38
39
40
41
42
43
# File 'lib/rails_event_store/async_handler_helpers.rb', line 36

def self.with(event_store: Rails.configuration.event_store, event_store_locator: nil)
  Module.new do
    define_method :perform do |payload|
      event_store = event_store_locator.call if event_store_locator
      super(event_store.read.event(payload.fetch("event_id")))
    end
  end
end

.with_defaultsObject



32
33
34
# File 'lib/rails_event_store/async_handler_helpers.rb', line 32

def self.with_defaults
  with
end