Class: Bricolage::StreamingLoad::LoaderMessage
- Inherits:
-
Bricolage::SQSMessage
- Object
- Bricolage::SQSMessage
- Bricolage::StreamingLoad::LoaderMessage
- Defined in:
- lib/bricolage/streamingload/loadermessage.rb
Direct Known Subclasses
Constant Summary
Constants inherited from Bricolage::SQSMessage
Bricolage::SQSMessage::SQS_EVENT_SOURCE
Instance Attribute Summary
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 Bricolage::SQSMessage
#body, create, for_sqs_record, for_sqs_result, get_event_time, #initialize, parse_sqs_record
Constructor Details
This class inherits a constructor from Bricolage::SQSMessage
Class Method Details
.get_concrete_class(msg, rec) ⇒ Object
9 10 11 12 13 14 |
# File 'lib/bricolage/streamingload/loadermessage.rb', line 9 def LoaderMessage.get_concrete_class(msg, rec) case when rec['eventName'] == 'streaming_load_v3' then StreamingLoadV3LoaderMessage else UnknownSQSMessage end end |
Instance Method Details
#data? ⇒ Boolean
20 21 22 |
# File 'lib/bricolage/streamingload/loadermessage.rb', line 20 def data? false end |
#message_type ⇒ Object
16 17 18 |
# File 'lib/bricolage/streamingload/loadermessage.rb', line 16 def raise "#{self.class}\#message_type must be implemented" end |