Class: Bricolage::StreamingLoad::FlushTableDispatcherMessage
- Inherits:
-
DispatcherMessage
- Object
- Bricolage::SQSMessage
- DispatcherMessage
- Bricolage::StreamingLoad::FlushTableDispatcherMessage
- Defined in:
- lib/bricolage/streamingload/dispatchermessage.rb
Constant Summary
Constants inherited from Bricolage::SQSMessage
Bricolage::SQSMessage::SQS_EVENT_SOURCE
Instance Attribute Summary collapse
-
#table_name ⇒ Object
readonly
Returns the value of attribute table_name.
Attributes inherited from Bricolage::SQSMessage
#delay_seconds, #message_id, #name, #receipt_handle, #source, #time
Class Method Summary collapse
Instance Method Summary collapse
Methods inherited from DispatcherMessage
Methods inherited from Bricolage::SQSMessage
for_sqs_record, for_sqs_result, get_event_time, #initialize
Constructor Details
This class inherits a constructor from Bricolage::SQSMessage
Instance Attribute Details
#table_name ⇒ Object (readonly)
Returns the value of attribute table_name.
87 88 89 |
# File 'lib/bricolage/streamingload/dispatchermessage.rb', line 87 def table_name @table_name end |
Class Method Details
.create(table_name:) ⇒ Object
71 72 73 |
# 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) ⇒ Object
75 76 77 78 79 |
# File 'lib/bricolage/streamingload/dispatchermessage.rb', line 75 def FlushTableDispatcherMessage.parse_sqs_record(msg, rec) { table_name: rec['tableName'] } end |
Instance Method Details
#body ⇒ Object
89 90 91 92 93 |
# File 'lib/bricolage/streamingload/dispatchermessage.rb', line 89 def body obj = super obj['tableName'] = @table_name obj end |
#init_message(table_name:) ⇒ Object
83 84 85 |
# File 'lib/bricolage/streamingload/dispatchermessage.rb', line 83 def (table_name:) @table_name = table_name end |