Method: Journaled::DeliveryJob#perform

Defined in:
app/jobs/journaled/delivery_job.rb

#perform(*events, **legacy_kwargs) ⇒ Object 



17
18
19
20
21
22
 
# File 'app/jobs/journaled/delivery_job.rb', line 17

def perform(*events, **legacy_kwargs)
  events << legacy_kwargs if legacy_kwargs.present?
  @kinesis_records = events.map { |e| KinesisRecord.new(**e.delete_if { |_k, v| v.nil? }) }

  journal! if Journaled.enabled?
end