class Bricolage::StreamingLoad::FlushTableDispatcherMessage
Attributes
table_name[R]
Public Class Methods
create(table_name:)
click to toggle source
Calls superclass method
Bricolage::SQSMessage::create
# File lib/bricolage/streamingload/dispatchermessage.rb, line 71 def FlushTableDispatcherMessage.create(table_name:) super name: 'flushtable', table_name: table_name end
parse_sqs_record(msg, rec)
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 75 def FlushTableDispatcherMessage.parse_sqs_record(msg, rec) { table_name: rec['tableName'] } end
Public Instance Methods
body()
click to toggle source
Calls superclass method
Bricolage::SQSMessage#body
# File lib/bricolage/streamingload/dispatchermessage.rb, line 89 def body obj = super obj['tableName'] = @table_name obj end
init_message(table_name:)
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 83 def init_message(table_name:) @table_name = table_name end