Class: Journaled::DeliveryJob

Inherits:
ApplicationJob show all
Defined in:
app/jobs/journaled/delivery_job.rb

Defined Under Namespace

Classes: KinesisRecord, KinesisTemporaryFailure

Instance Method Summary collapse

Instance Method Details

#perform(*events) ⇒ Object 



15
16
17
18
19
 
# File 'app/jobs/journaled/delivery_job.rb', line 15

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

  journal! if Journaled.enabled?
end