Class: Journaled::DeliveryJob

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

Defined Under Namespace

Classes: KinesisRecord, KinesisTemporaryFailure

Constant Summary collapse

DEFAULT_REGION = 
'us-east-1'

Instance Method Summary collapse

Instance Method Details

#kinesis_client_config ⇒ Object 



23
24
25
26
27
28
29
30
31
 
# File 'app/jobs/journaled/delivery_job.rb', line 23

def kinesis_client_config
  {
    region: ENV.fetch('AWS_DEFAULT_REGION', DEFAULT_REGION),
    retry_limit: 0,
    http_idle_timeout: Journaled.http_idle_timeout,
    http_open_timeout: Journaled.http_open_timeout,
    http_read_timeout: Journaled.http_read_timeout,
  }.merge(credentials)
end

#perform(*events) ⇒ Object 



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

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

  journal! if Journaled.enabled?
end