class Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage

Attributes

task_id[R]

Public Class Methods

create(task_id:, force: false) click to toggle source
Calls superclass method Bricolage::SQSMessage::create
# File lib/bricolage/streamingload/loadermessage.rb, line 33
def StreamingLoadV3LoaderMessage.create(task_id:, force: false)
  super name: 'streaming_load_v3', task_id: task_id, force: force
end
for_load_task(load_task) click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 29
def StreamingLoadV3LoaderMessage.for_load_task(load_task)
  create(task_id: load_task.id)
end
parse_sqs_record(msg, rec) click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 37
def StreamingLoadV3LoaderMessage.parse_sqs_record(msg, rec)
  {
    task_id: rec['taskId'],
    force: (rec['force'].to_s == 'true')
  }
end

Public Instance Methods

body() click to toggle source
Calls superclass method Bricolage::SQSMessage#body
# File lib/bricolage/streamingload/loadermessage.rb, line 57
def body
  obj = super
  obj['taskId'] = @task_id
  obj['force'] = true if @force
  obj
end
force?() click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 53
def force?
  !!@force
end
init_message(task_id:, force: false) click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 46
def init_message(task_id:, force: false)
  @task_id = task_id
  @force = force
end