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