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